我要用Kafka的手动偏移提交。有没有一种方法可以在执行consumer.commitofsets（）时获取提交的偏移量列表；p、 我使用的是高级消费者。
qzlgjiam1#
不确定您使用的是什么Kafka版本或客户端（即语言）。java高级消费者产品
KafkaConsumer#committed(TopicPartition partition);
接收分区的最新提交偏移量。因此，您可以在完成提交后调用它。https://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/consumer/kafkaconsumer.html如果您想在执行提交之前知道偏移量，那么需要获取最后一个消息的每个分区的最后一条消息的偏移量 poll() . 因此，在 poll() 在处理您的记录时，您需要通过
poll()
ConsumerRecord#offset()
https://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/consumer/consumerrecord.html
1条答案
按热度按时间qzlgjiam1#
不确定您使用的是什么Kafka版本或客户端（即语言）。java高级消费者产品
接收分区的最新提交偏移量。因此，您可以在完成提交后调用它。
https://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/consumer/kafkaconsumer.html
如果您想在执行提交之前知道偏移量，那么需要获取最后一个消息的每个分区的最后一条消息的偏移量
poll(). 因此，在poll()在处理您的记录时，您需要通过https://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/consumer/consumerrecord.html