You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2021/09/25 19:24:00 UTC
[jira] [Commented] (KAFKA-12983) onJoinPrepare is not always
invoked before joining the group
[ https://issues.apache.org/jira/browse/KAFKA-12983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420155#comment-17420155 ]
Matthias J. Sax commented on KAFKA-12983:
-----------------------------------------
[~ableegoldman] Do we actually know if 2.6 is also affected?
> 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: 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.3.4#803005)