Relative Content

Tag Archive for apache-kafkaksqldbflink-sqlconfluent-cloud

Dynamic Field Access for Kafka Header Message using ksqlDB

I am using Confluent Cloud Kafka and want more observability. Therefore I want to monitor it using Splunk. I have several Topics and want to extract the Header information from the messages, send them to Topic_HEADERS, using ksqlDB, which holds the Header information then. This Topic_B should then be added to a Splunk_Sink_Connector in order to get it into Splunk. Confluent Cloud Kafka is already up and running, as well as the Topics and the Splunk_Sink_Connector. I also have the data in Splunk, but my problem is that I need to flatten the records.