Python Kafka：如何从我停止的地方继续消费消息

Question

我正在使用Kafka python版本2.0.2来生成和消费消息：我的生产者：

from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers='my server')
producer.send('my topic', b'hello word')

我的消费者:

consumer = kafka.KafkaConsumer('my topic',bootstrap_servers=['192.168.2.137:9092'],
auto_offset_reset='earliest',
enable_auto_commit=True,
group_id='name')
    
for message in consumer:    
    print(message.value)

当我运行消费者时，它运行得很好。但是当我在它完成所有消息之前停止它时，它不会从我停止的地方继续，如果我的程序崩溃或笔记本电脑没电了怎么办？我如何解决每个问题？我希望消费者继续阅读未阅读的消息？

Answer 1

尝试将偏移重置配置更改为最新（这是默认值）。

consumer = kafka.KafkaConsumer('my topic',bootstrap_servers=['192.168.2.137:9092'],
auto_offset_reset='latest',
enable_auto_commit=True,
group_id='name')
    
for message in consumer:    
    print(message.value)