You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/07/23 22:59:00 UTC

[jira] [Assigned] (KAFKA-7196) Remove heartbeat delayed operation for those removed consumers at the end of each rebalance

     [ https://issues.apache.org/jira/browse/KAFKA-7196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dong Lin reassigned KAFKA-7196:
-------------------------------

    Assignee: Lincong Li

> 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
>   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)