如何将kafka connect中的sourcerecord转换为avro？

xsuvu9jc 于 2021-06-05 发布在 Kafka

关注(0)|答案(1)|浏览(357)

我有一个用例需要转换 SourceRecord 到 GenericRecord . 有人能帮我怎么做吗？
基本上，我正在编写一个定制的kafka生产者，并将其嵌入connect运行时代码中。当 producer.send() 调用时，sourcerecord将转换为 ProducerRecord<byte[],byte[]> 类型。现在，从这里，我如何得到一个 GenericRecord 这样我就可以执行自定义任务了？

avro apache-kafka apache-kafka-connect kafka-producer-api

来源：https://stackoverflow.com/questions/60421988/how-can-we-convert-a-sourcerecord-in-kafka-connect-to-avro