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