从结构体重建 avro 对象

Reconstructing avro Object from a Struct

我正在使用 Kafka Connect 处理来自我的 Kafka 主题的消息,当我收到包含 Avro 消息的 SinkRecord 时,我得到的值是类型“Struct”,这是 Kafka Connect 特定的类型“org.apache.kafka.connect.data.Struct" 但是,我更感兴趣的是获取此 Struct 表示的特定对象(例如 'Customer' 对象,它具有我想看到的所有 getters/setters)

是否有使用 Kafka Connect 将“Struct”对象映射回“Customer”对象的简单方法?

在 Confluent AvroData class 中,fromConnectData 就是这样做的。