You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2015/09/22 22:17:04 UTC
[jira] [Created] (KAFKA-2568) New consumer hangs indefinitely when
broker list is misconfigured
Jason Gustafson created KAFKA-2568:
--------------------------------------
Summary: New consumer hangs indefinitely when broker list is misconfigured
Key: KAFKA-2568
URL: https://issues.apache.org/jira/browse/KAFKA-2568
Project: Kafka
Issue Type: Bug
Affects Versions: 0.9.0.0
Reporter: Jason Gustafson
Assignee: Jason Gustafson
If you accidentally point the broker list configuration to something other than an 0.9 Kafka cluster, the consumer will hang indefinitely in poll() while it tries to discover the coordinator. This is less than ideal for users since it provides no indication of the problem. An incompatible server could respond in two ways:
1. It may send back an invalid response.
2. It may just terminate the connection.
The first case is straightforward: we should get an ApiException which can be propagated to the user. The second case is trickier since it's difficult to distinguish this case from a regular broker failure. We might see this happen if the new consumer is pointed to an 0.8 broker for example. I'm not sure there's much we can do in this case other than making the disconnects visible in logging, but that is better than eating the errors silently.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)