[
https://issues.apache.org/jira/browse/KAFKA-7196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589247#comment-16589247
]
ASF GitHub Bot commented on KAFKA-7196:
---------------------------------------
Lincong opened a new pull request #5556: KAFKA-7196: Remove heartbeat delayed
operation for those removed cons…
URL: https://github.com/apache/kafka/pull/5556
### Description
During the consumer group rebalance, when the joining group phase finishes,
the heartbeat delayed operation of the consumer that fails to rejoin the group
should be removed from the purgatory. Otherwise, even though the member ID of
the consumer has been removed from the group, its heartbeat delayed operation
is still registered in the purgatory and the heartbeat delayed operation is
going to timeout and then another unnecessary rebalance is triggered because of
it.
### Summary of testing strategy
Extend one of the existing unit test
"testRebalanceCompletesBeforeMemberJoins" to verify that the delayed heart beat
operation has actually been removed so that it would not trigger another
unnecessary group rebalance.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
> Remove heartbeat delayed operation for those removed consumers at the end of
> each rebalance
> -------------------------------------------------------------------------------------------
>
> Key: KAFKA-7196
> URL: https://issues.apache.org/jira/browse/KAFKA-7196
> Project: Kafka
> Issue Type: Bug
> Components: core, purgatory
> Reporter: Lincong Li
> Assignee: Lincong Li
> Priority: Minor
> Fix For: 2.1.0
>
> Original Estimate: 24h
> Remaining Estimate: 24h
>
> During the consumer group rebalance, when the joining group phase finishes,
> the heartbeat delayed operation of the consumer that fails to rejoin the
> group should be removed from the purgatory. Otherwise, even though the member
> ID of the consumer has been removed from the group, its heartbeat delayed
> operation is still registered in the purgatory and the heartbeat delayed
> operation is going to timeout and then another unnecessary rebalance is
> triggered because of it.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
