Python：后台Kafka consumer offset commit

Question

from kafka import KafkaConsumer

task_event = TaskEvent()

consumer = KafkaConsumer('test',bootstrap_servers=["localhost:9092"],group_id=None, auto_offset_reset='smallest')
for msg in consumer:
    print msg.offset

0 
1
2 
.
.
16

是什么决定了Kafka消费者抵消？--根据接受的答案，您在一个消费者组group1中有一个消费者已经消费了5条消息并死亡。下一次启动这个使用者时，它甚至不会使用auto.offset.reset配置，而会从它死的地方继续，因为它只会从偏移量存储中获取存储的偏移量

根据Python API文档http://kafka-python.readthedocs.io/en/master/apidoc/kafkaconsumer.html，enable_auto_commit默认为true，这意味着使用者的偏移量应该在后台提交。但是，当我停止并多次运行上述操作时，我得到的输出是相同的，如果auto_commit默认为true（假设规则对任何API都是相同的，可能是Java或Python），则不希望得到相同的输出。

多谢了。

Answer 1

根据文档,

group_id(str或None)-要加入动态分区分配（如果启用）并用于获取和提交偏移量的使用者组的名称。如果没有，则禁用自动分区分配（通过组协调器）和偏移量提交。

在上面的代码中，组id是none。我更改了它，并给出了一个组名，并且正在提交偏移。