apache-kafka - 如何从 KafkaItemReader SpringBatch 中检索 Kafka 记录元数据
问题描述
我正在使用 Spring Batch KafkaItemReader 使用 Avro Schema 读取和反序列化 Kafka Avro 消息到 GenericRecord。除了我还需要为该记录使用元数据（如时间戳、分区、偏移量等）以在处理器中应用转换之外，一切工作正常。
我们可以借助 spring-kafka 中 @kafkalistener 注释方法中的标头获取消费者记录元数据，但我没有找到任何实现来在 Spring Batch KafkaItemReader 中获取元数据。你们中的任何人都可以建议如何在 spring-batch 中从 KafkaItemReader 实现中获取记录元数据。
@MahmoudBinHassine
谢谢