Using debezium to parse binlog, using avro serialization and send to kafka.
Need to consume the avro serialized binlog data and wirite to target database I want to use self-written java code instead of kafka jdbc sink connector. How can i reference the schema registry, convert a kafka message to corresponding table record and write to corresponding table? Is there any example code to do this ? Thanks, Lei wangl...@geekplus.com.cn
