从结构体重建 avro 对象

Question

我正在使用 Kafka Connect 处理来自 Kafka 主题的消息，当我收到包含 Avro 消息的 SinkRecord 时，我得到的值是“Struct”类型，这是 Kafka Connect“org.apache.kafka.h” 特有的值。 connect.data.Struct”但是，我更感兴趣的是获取此 Struct 代表的特定对象（例如，具有我希望看到的所有 getter/setter 的“Customer”对象）

是否有一种简单的方法可以使用 Kafka Connect 将“Struct”对象映射回“Customer”对象？

Answer 1

在 Confluence AvroData 类中，有 fromConnectData 可以做到这一点。