You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "dybyte (via GitHub)" <gi...@apache.org> on 2026/09/18 16:07:35 UTC
[PR] KAFKA-17734: Reset group state before polling in maybeLeaveGroup [kafka]
dybyte opened a new pull request, #23512:
URL: https://github.com/apache/kafka/pull/23512
`maybeLeaveGroup()` polls the network client right after sending LeaveGroup,
while the member state is still `PREPARING_REBALANCE`. If a JoinGroup response
of an in-flight rebalance is pending, that poll processes it; when this member
is elected leader, `onLeaderElected()` waits for a metadata refresh with an
unbounded timer. With brokers unreachable, `close()` never returns regardless of
its timeout, and `wakeup()` cannot interrupt it since `close()` disables wakeups.
Reset the state to `UNJOINED` before polling, so the JoinGroup handler discards
the response instead of driving a rebalance for a member that is leaving.
Added a test that delivers a leader-electing JoinGroup response during the
LeaveGroup poll with brokers backed off. It hangs on trunk and passes with this
change.
Co-Authored-By: Claude
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-17734: Reset group state before polling in maybeLeaveGroup [kafka]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on PR #23512:
URL: https://github.com/apache/kafka/pull/23512#issuecomment-5883006343
A label of 'needs-attention' was automatically added to this PR in order to raise the
attention of the committers. Once this issue has been triaged, the `triage` label
should be removed to prevent this automation from happening again.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org