Hi Lei, You could use the Kafka Avro consumer to deserialise records using the Schema Registry automatically.
Then write to the DB as you see fit. Cheers, Liam Clarke-Hutchinson On Sat, 9 May 2020, 2:38 pm [email protected], < [email protected]> wrote: > > 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 > > > > [email protected] > >
