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

Posted to jira@kafka.apache.org by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2021/06/23 01:58:00 UTC

[jira] [Created] (KAFKA-12983) onJoinPrepare is not always invoked before joining the group

A. Sophie Blee-Goldman created KAFKA-12983:
----------------------------------------------

             Summary: onJoinPrepare is not always invoked before joining the group
                 Key: KAFKA-12983
                 URL: https://issues.apache.org/jira/browse/KAFKA-12983
             Project: Kafka
          Issue Type: Bug
          Components: consumer
            Reporter: A. Sophie Blee-Goldman
             Fix For: 3.0.0, 2.8.1


As the title suggests, the #onJoinPrepare callback is not always invoked before a member (re)joins the group, but only once when it first enters the rebalance. This means that any updates or events that occur during the join phase can be lost in the internal state: for example, clearing the SubscriptionState (and thus the "ownedPartitions" that are used for cooperative rebalancing) after losing its memberId during a rebalance.

We should reset the `needsJoinPrepare` flag inside the resetStateAndRejoin() method



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