[ https://issues.apache.org/jira/browse/KAFKA-3971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410194#comment-15410194 ]
Jason Gustafson commented on KAFKA-3971: ---------------------------------------- I'm trying to understand your usage a little better. It sounds like you are saying each topic is consumed by a separate consumer, but all consumers in the same process share the same group id. Is that right? > Consumers drop from coordinator and cannot reconnet > --------------------------------------------------- > > Key: KAFKA-3971 > URL: https://issues.apache.org/jira/browse/KAFKA-3971 > Project: Kafka > Issue Type: Bug > Components: consumer > Affects Versions: 0.9.0.1 > Environment: version 0.9.0.1 > Reporter: Lei Wang > Attachments: KAFKA-3971.txt > > > From time to time, we're creating new topics, and all consumers will pickup > those new topics. When starting to consume from these new topics, we often > see some of random consumers cannot connect to the coordinator. The log will > be flushed with the following log message tens of thousands every second: > {noformat} > 16/07/18 18:18:36.003 INFO (AbstractCoordinator.java:529): Marking the > coordinator 2147483645 dead. > 16/07/18 18:18:36.004 INFO (AbstractCoordinator.java:529): Marking the > coordinator 2147483645 dead. > 16/07/18 18:18:36.004 INFO (AbstractCoordinator.java:529): Marking the > coordinator 2147483645 dead. > 16/07/18 18:18:36.004 INFO (AbstractCoordinator.java:529): Marking the > coordinator 2147483645 dead. > 16/07/18 18:18:36.004 INFO (AbstractCoordinator.java:529): Marking the > coordinator 2147483645 dead. > 16/07/18 18:18:36.004 INFO (AbstractCoordinator.java:529): Marking the > coordinator 2147483645 dead. > 16/07/18 18:18:36.004 INFO (AbstractCoordinator.java:529): Marking the > coordinator 2147483645 dead. > 16/07/18 18:18:36.004 INFO (AbstractCoordinator.java:529): Marking the > coordinator 2147483645 dead. > 16/07/18 18:18:36.004 INFO (AbstractCoordinator.java:529): Marking the > coordinator 2147483645 dead. > 16/07/18 18:18:36.004 INFO (AbstractCoordinator.java:529): Marking the > coordinator 2147483645 dead. > 16/07/18 18:18:36.004 INFO (AbstractCoordinator.java:529): Marking the > coordinator 2147483645 dead. > 16/07/18 18:18:36.004 INFO (AbstractCoordinator.java:529): Marking the > coordinator 2147483645 dead. > 16/07/18 18:18:36.004 INFO (AbstractCoordinator.java:529): Marking the > coordinator 2147483645 dead. > 16/07/18 18:18:36.005 INFO (AbstractCoordinator.java:529): Marking the > coordinator 2147483645 dead. > {noformat} > the servers seem working fine, and other consumers are also happy. > from the log, looks like it's retrying multiple times every millisecond but > all failing. > the same process are consuming from many topics, some of them are still > working well, but those random topics will fail. -- This message was sent by Atlassian JIRA (v6.3.4#6332)