Java Kafka消费者处理二进制图像数据

Question

我是Kafka的新手，目前需要提取二进制图像数据。我目前正在使用KafkaAvroDeserializer。ConsumerRecord<byte[]、byte[]>是：

Key {"prim_key": -99999999, "seq": 1} 
value {"beforeImage": null, "afterImage": {"prim_key": -99999999, "seq": 1, "bin_data": {"bytes": ..................}}}

我如何提取"；字节"；原始字节数据？

Answer 1

如果您使用Avro反序列化程序，那么您不会使用字节数组作为记录类型，您可以使用ConsumerRecord<GenericRecord, GenericRecord>，然后从数据中提取适当的字段

否则，如果你只需要字节数组，生产者会使用ByteArraySerializer，它与Avro反序列化器不兼容