Flatten CDC records in KSQL
The problem - nested messages in Kafka
Data comes into Kafka in many shapes and sizes. Sometimes it’s from CDC tools, and may be nested like this:
Data comes into Kafka in many shapes and sizes. Sometimes it’s from CDC tools, and may be nested like this: