You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Luan Hongjun <lu...@gmail.com> on 2018/08/02 01:53:57 UTC
My client's kafka consumer disappears
Hi Someone,
I've encountered a strange problem.
I write a consumer with python to get data from 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
......
It runs for about one day. And then I couldn't find my consumer group from
./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --list
But my python process is running. I try tcpdump and find that the app is
still trying to connect kafka. But no data responsed.
And I installed kafka with tar file not docker image.
Could anyone help me?
Thanks a lot