Python KafkaConsumer 不打印输出答案

【问题标题】：Python KafkaConsumer not printing outputPython KafkaConsumer 不打印输出
【发布时间】：2021-07-12 10:43:43
【问题描述】：

我正在使用以下脚本从 kafka 读取数据 -

from kafka import KafkaConsumer
from json import loads
import json

consumer = KafkaConsumer('topicname',bootstrap_servers=['brokerip'],enable_auto_commit=True)
 
 for message in consumer:
     message = message.value
     print(message)

当我第一次运行代码时它正在工作，但现在它没有打印任何东西。代码没有任何变化。为什么会发生这种情况？

【问题讨论】：

标签： apache-kafka kafka-python

【解决方案1】：

当我第一次运行代码时它正在工作

您已为您的消费者组 (enable_auto_commit=True) 提交了消息，并且没有正在积极生成的消息。

如果你想重复消息，你需要重置消费者组或使用一个新的

【讨论】：