You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Guozhang Wang (Jira)" <ji...@apache.org> on 2020/01/07 23:53:00 UTC

[jira] [Created] (KAFKA-9382) Allow consumers to commit offset in the middle of a rebalance

Guozhang Wang created KAFKA-9382:
------------------------------------

             Summary: Allow consumers to commit offset in the middle of a rebalance
                 Key: KAFKA-9382
                 URL: https://issues.apache.org/jira/browse/KAFKA-9382
             Project: Kafka
          Issue Type: Improvement
          Components: consumer
            Reporter: Guozhang Wang
            Assignee: Jason Gustafson


After we've done KAFKA-8421 we should consider letting consumers to allow committing in the middle of a rebalance --- at the moment it will throw a non-fatal rebalance-in-progress exception --- so that users do not need to worry and handle this transient error when unnecessary. It involves:

1) On client side, not checking the "REBALANCING" state and throw immediately.
2) On client side, capture and handle illegal generation if in "REBALANCING" and retry with the current assigned partitions.
3) On client side, use different connections for join/sync-group requests and for committing / fetching offsets.
4) On broker side, during CompletingRebalance accept the commit request with correct generation id instead of returning REBALANCE_IN_PROGRESS error code.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)