在Kafka中讀取偏移量

Question

我正在使用Kafka上的手動偏移量提交。有沒有辦法獲得每當我做consumer.commitOffsets（）; P.S.我正在使用高級消費者。

Answer 1

不確定您使用的是什麼Kafka版本或客​​戶端（即語言）。 Java高級消費者報價

KafkaConsumer#committed(TopicPartition partition); 

接收最新的提交的分區偏移量。因此，您可以在完成提交後調用它。

https://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html

如果你想知道你在做之前提交的偏移量，則需要每最後poll()的分區中的每一最後消息得到補償。因此，poll()後處理您的記錄時，你需要通過

ConsumerRecord#offset() 

https://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/consumer/ConsumerRecord.html

得到這個信息