Jason Gustafson created KAFKA-3528:
--------------------------------------
Summary: AbstractCoordinator wakeup during rebalance can cause
spurious rebalances
Key: KAFKA-3528
URL: https://issues.apache.org/jira/browse/KAFKA-3528
Project: Kafka
Issue Type: Bug
Components: consumer, KafkaConnect
Affects Versions: 0.9.0.1, 0.9.0.0
Reporter: Jason Gustafson
Assignee: Jason Gustafson
If the user calls wakeup() while a rebalance is pending, the join/sync will be
left on the wire. Although the requests will eventually complete on a later
call to poll(), since we have aborted the call to ensureActiveGroup(), the
onJoinComplete() callback will never be invoked. This causes a spurious
rebalance on the next poll() since we never received the assignment for the
joined generation. This also affects Kafka Connect, which depends internally on
the group management protocol and uses wakeup to break from poll() in order to
handle requests.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
