[ https://issues.apache.org/jira/browse/KAFKA-12983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Guozhang Wang updated KAFKA-12983: ---------------------------------- Labels: new-consumer-threading-should-fix (was: ) > 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 > Affects Versions: 2.7.0 > Reporter: A. Sophie Blee-Goldman > Assignee: A. Sophie Blee-Goldman > Priority: Blocker > Labels: new-consumer-threading-should-fix > Fix For: 2.7.2, 2.8.1, 3.0.0 > > > 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.20.7#820007)