kafka-python while loop goes down

[murdercdh]

In my python code I have:

group = mytest
 try:
       consumer = KafkaConsumer(bootstrap_servers=kafka_multi_hosts, auto_offset_reset='latest', enable_auto_commit=False, group_id=self.topics['customer']['group'], reconnect_backoff_ms=1,consumer_timeout_ms=1000)
       break
 except Exception, err:

while True:
   try:
     for msg in consumer:
        #do the work
     except Exception, err:
        #manage exception ! not possible in 1.3.5

My consumer is trying to read all messages within group = mytest. My kafka cluster is formed by 3 zk and 3 kafka nodes.

kubectl get pods -n kafka
NAME      READY     STATUS    RESTARTS   AGE
kafka-0   1/1       Running   3          7m
kafka-1   1/1       Running   0          4m
kafka-2   1/1       Running   0          3m
zk-0      1/1       Running   0          49m
zk-1      1/1       Running   0          7m
zk-2      1/1       Running   0          1h

I have the same issue when I using the similar code. My sentry log alert me every day~~~.

Originally posted by @murdercdh in #1354 (comment)