Dongnuo Lyu created KAFKA-16178: ----------------------------------- Summary: AsyncKafkaConsumer doesn't retry joining the group after rediscovering group coordinator Key: KAFKA-16178 URL: https://issues.apache.org/jira/browse/KAFKA-16178 Project: Kafka Issue Type: Bug Components: clients, consumer Reporter: Dongnuo Lyu Attachments: pkc-devc63jwnj_jan19_0_debug
Some of the consumers don't consume any message. The logs show that after the consumer starts up and successfully logs in, # The consumer discovers the group coordinator. # The heartbeat to join group fails because "This is not the correct coordinator" # The consumer rediscover the group coordinator. Another heartbeat should follow the rediscovery of the group coordinator but there's no logs showing sign of a heartbeat request. On the server side, there is completely no log about the group id. A suspicion is that the consumer doesn't send a heartbeat request after rediscover the group coordinator. -- This message was sent by Atlassian Jira (v8.20.10#820010)