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)
