[ https://issues.apache.org/jira/browse/KAFKA-12983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
A. Sophie Blee-Goldman reassigned KAFKA-12983: ---------------------------------------------- Assignee: A. Sophie Blee-Goldman > 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 > Assignee: A. Sophie Blee-Goldman > Priority: Blocker > 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)