Hello, I have a current flow where the data from the Flink-Kafka connector is captured and processed using Flink Datastream API and stored in Kafka topics. However, I would like to make it CDC enabled. I went through an article where it was mentioned that it should be handled on the Kafka side while capturing the data. I mean CDC should be handled on the Kafka side. Or should I need to use Table API?
So, any ideas/links are much appreciated as I am trying to understand these concepts. TIA, Sid
