0

API 文档在这里: http: //kafka-python.readthedocs.org/en/latest/apidoc/kafka.consumer.html

kafka.consumer.simple.SimpleConsumer.offsets 和 kafka.consumer.simple.SimpleConsumer.fetch_offsets 有什么区别(https://github.com/mumrah/kafka-python/blob/adbd4ac052e4a5b40cfc2a3589b7adbcb656afe5/kafka/consumer/simple.py )?

如何获取一个主题的某个分区的所有消息的偏移量?如何获取未消费消息的偏移量?如何获取已消费消息的偏移量?似乎 offsets 和 fetch_offsets 都是消费消息的偏移量。

4

0 回答 0