Category "cdc"

No data in the changelog topic for a KSQL table

Step 1. Postgres CDC Data I have a Postgres table which has been set up to use Debezium PostgreSQL Connector to generate CDC. In Kafka, I can see the CDC data i

How to write Debezium Connector Configuration and Debezium Listener for mongoDB in spring-boot and before, after payload as JSON?

Could anyone please provide the sample code in spring-boot for Debezium connector Listeners class and configuration class for MongoDB which provide the changed

Debezium mySql connecter not able to capture insert and updater operation

I am trying to implemnt CDC piline with Debezium mysql connecter and kafkal But Source connecter not able to pusblish event for insert and update operation in t

How to do type conversion when transferring data from MongoDB to kafka with debezium?

In Mongodb, the objectid is base64. I'm streaming these docs to Kafka using Debezium. How can I get ObjectId to be written as UUID in kafka? Mongo Example Doc :