You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/06/05 15:52:00 UTC

[jira] [Created] (KAFKA-8487) Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit response handler

Guozhang Wang created KAFKA-8487:
------------------------------------

             Summary: Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit response handler
                 Key: KAFKA-8487
                 URL: https://issues.apache.org/jira/browse/KAFKA-8487
             Project: Kafka
          Issue Type: Improvement
          Components: consumer
            Reporter: Guozhang Wang
            Assignee: Guozhang Wang


In consumer, we handle the errors in sync / heartbeat / join response such that:

1. UNKNOWN_MEMBER_ID / ILLEGAL_GENERATION: we reset the generation and request re-join.

2. REBALANCE_IN_PROGRESS: do nothing if a rejoin will be executed, or request re-join explicitly.

However, for commit response, we require resetGeneration for REBALANCE_IN_PROGRESS as well. This is a flaw in two folds:

1. As in KIP-345, with static members, reseting generation will lose the member.id and hence may cause incorrect fencing.

2. As in KIP-429, resetting generation will cause partitions to be "lost" unnecessarily before re-joining the group. 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)