Writing Custom Kafka Converter to Convert Debezium Source to Protobuf

backend1 Min to Read25 Sep 21

postgres, debezium, kafka, zookeeper, consumer, producer

what is this


Debezium sends DB event to kafka in json schema but if you have kafka-consumer which expect protobuf schema then it will not work.But If you have kafka-consumer which expect json schema then it is not a problem.

debezium convert DB update event json and serialize into string before sending to kafka. So producer who expecting in protobuf schema will not work.

Debezium has out of box support for json schema.


postgres setup

kafka & zookeeper setup

kafka consumer setup json protobuf

debezium setup


docker setup

If you loved this post, Please share it on social media.