我有一种在shell中执行此任务的方法：如何使kafka consumer从上次使用的偏移量而不是从开始读取但是，我愿意用python，使用 kafka-python 我找不到这个案子的api。http://kafka-python.readthedocs.io/en/latest/apidoc/kafkaconsumer.html
kafka-python
r7xajy2e1#
启用具有 kafka-python 你只需要设置 group_id 消费者中的配置。从使用者api：group\u id（str或none）–要加入以进行动态分区分配（如果启用）以及用于获取和提交偏移量的使用者组的名称。如果没有，则禁用自动分区分配（通过组协调器）和偏移提交。默认值：无如果您将其设置为任何值，使用者将自动提交其读取的偏移量，并在关闭时从该位置重新启动。
group_id
1条答案
按热度按时间r7xajy2e1#
启用具有
kafka-python你只需要设置group_id消费者中的配置。从使用者api：
group\u id（str或none）–要加入以进行动态分区分配（如果启用）以及用于获取和提交偏移量的使用者组的名称。如果没有，则禁用自动分区分配（通过组协调器）和偏移提交。默认值：无
如果您将其设置为任何值，使用者将自动提交其读取的偏移量，并在关闭时从该位置重新启动。