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

Reply via email to