[
https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16154137#comment-16154137
]
Geoffrey Stewart commented on KAFKA-5016:
-----------------------------------------
Thanks for your repsonse [~hachikuji]
The way you have explained this is certainly consistent with the behavior we
are seeing. I think the cause for my confusion comes from the Kafka docs. For
example, at the link:
[https://kafka.apache.org/documentation/#newconsumerconfigs]
If you search for the parameter "heartbeat.interval.ms" It is written here:
"Heartbeats are used to ensure that the consumer's session stays active and to
facilitate rebalancing when new consumers join or leave the group."
This gives the impression that the heartbeat is used to enable rebalances to
complete, which is different than what you are saying. Do you think that the
docs should be updated to reflect the actual behavior?
> Consumer hang in poll method while rebalancing is in progress
> -------------------------------------------------------------
>
> Key: KAFKA-5016
> URL: https://issues.apache.org/jira/browse/KAFKA-5016
> Project: Kafka
> Issue Type: Bug
> Components: core
> Affects Versions: 0.10.1.0, 0.10.2.0
> Reporter: Domenico Di Giulio
> Assignee: Vahid Hashemian
> Attachments: Kafka 0.10.2.0 Issue (TRACE) - Server + Client.txt,
> Kafka 0.10.2.0 Issue (TRACE).txt, KAFKA_5016.java
>
>
> After moving to Kafka 0.10.2.0, it looks like I'm experiencing a hang in the
> rebalancing code.
> This is a test case, not (still) production code. It does the following with
> a single-partition topic and two consumers in the same group:
> 1) a topic with one partition is forced to be created (auto-created)
> 2) a producer is used to write 10 messages
> 3) the first consumer reads all the messages and commits
> 4) the second consumer attempts a poll() and hangs indefinitely
> The same issue can't be found with 0.10.0.0.
> See the attached logs at TRACE level. Look for "SERVER HANGS" to see where
> the hang is found: when this happens, the client keeps failing any hearbeat
> attempt, as the rebalancing is in progress, and the poll method hangs
> indefinitely.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
