我遇到了一个奇怪的问题。我用python编写了一个consumer来从kafka获取数据。
self.consumer = KafkaConsumer(self.kafkatopic,
group_id=self.groupid,bootstrap_servers=self.kafkaservers,
auto_offset_reset="earliest")
for message in self.consumer:
messageText = message.value它成功运行了大约一天。但一天之后，我在Running找不到我的消费群：
./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --list我的python进程仍在运行。我尝试tcpdump，发现应用程序仍然在尝试连接Kafka。但没有数据回应。有人能帮我吗？
1条答案
按热度按时间5ssjco0h1#
我认为问题是版本差异造成的。我的python-kafka-sdk版本低于kafka版本，我用java重新实现了逻辑。javakafkasdk的版本与kafka的相同。然后问题就解决了。