我正在使用GenericRecord消费avro消息。
final KStream<String, org.apache.avro.generic.GenericRecord> kStream = streamsBuilder
.stream(topicName, Consumed.with(Serdes.String(),genericAvroSerde));我需要获取消费记录的偏移量、分区值和时间戳。那么，有没有人能指导我如何获得这些值。
提前感谢您的帮助
我正在使用GenericRecord消费avro消息。
final KStream<String, org.apache.avro.generic.GenericRecord> kStream = streamsBuilder
.stream(topicName, Consumed.with(Serdes.String(),genericAvroSerde));我需要获取消费记录的偏移量、分区值和时间戳。那么，有没有人能指导我如何获得这些值。
提前感谢您的帮助
1条答案
按热度按时间gg0vcinb1#
使用Kafka Streams DSL是不可能获得这些值的。
然而，处理器API可以
https://kafka.apache.org/32/javadoc/org/apache/kafka/streams/processor/ProcessorContext.html