我是新来Kafka,目前有一个需要提取二进制图像数据。我现在用的是Kafka夫罗德序列器。consumerrecord<byte[],byte[]>的键和值为:
Key {"prim_key": -99999999, "seq": 1}
value {"beforeImage": null, "afterImage": {"prim_key": -99999999, "seq": 1, "bin_data": {"bytes": ..................}}}
如何提取“字节”原始字节数据?
1条答案
按热度按时间svdrlsy41#
如果您使用的是avro反序列化程序,那么就不会使用字节数组作为记录类型,您可以使用
ConsumerRecord<GenericRecord, GenericRecord>
,然后从数据中提取相应的字段否则,如果您只需要字节数组,生产者将使用bytearrayserializer,这将与avro反序列化程序不兼容