Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
KAFKA-7196; Remove heartbeat delayed operation for those removed cons…
…umers at the end of each rebalance 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. Author: Lincong Li <lcli@linkedin.com> Reviewers: Dong Lin <lindong28@gmail.com> Closes #5556 from Lincong/remove_heartbeat_delayedOperation (cherry picked from commit 260b07a) Signed-off-by: Dong Lin <lindong28@gmail.com>
- Loading branch information