Flatten Dynamic Accessed Fields for Kafka Header Message using ksqlDB or Flink-SQL
UPDATE:
I am now using these Streams:
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.