如何将Kafka Connect中的SourceRecord转换为AVRO？

Question

我有一个使用案例，我需要将一个 SourceRecord 到 GenericRecord. 谁能帮助我如何做到这一点？

基本上，我正在编写一个自定义的Kafka Producer，并将其嵌入到Connect运行时的代码中。当 producer.send() 调用，SourceRecord就会被转换为一个 ProducerRecord<byte[],byte[]> 类型。现在，从这一点来看，我如何获得一个 GenericRecord 以便我可以执行我的自定义任务？

Answer 1

看看Confluent AvroData 类，其中有一些方法可以从连接数据SchemaStruct类（嵌入到SourceRecord的keyvalue中）中获取。在那里有一些方法来从Connect Data SchemaStruct类（它被嵌入到SourceRecord的keyvalue中）。