[jira] [Created] (KAFKA-16258) Stale member should trigger onPartitionsLost when leaving group

["Lianet Magrans (Jira)" <ji...@apache.org>]

Lianet Magrans created KAFKA-16258:
--------------------------------------

             Summary: Stale member should trigger onPartitionsLost when leaving group
                 Key: KAFKA-16258
                 URL: https://issues.apache.org/jira/browse/KAFKA-16258
             Project: Kafka
          Issue Type: Sub-task
          Components: clients, consumer
    Affects Versions: 3.7.0
            Reporter: Lianet Magrans
             Fix For: 3.8.0


When the poll timer expires, the new consumer proactively leaves the group and clears its assignments, but it should also invoke the onPartitionsLost callback. The legacy coordinator does the following sequence on poll timer expiration: send leave group request ([here|https://github.com/apache/kafka/blob/e8c70fce26626ed2ab90f2728a45f6e55e907ec1/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java#L1517]), invoke onPartitionsLost, and when it completes it clears the assignment (onJoinPrepare [here|https://github.com/apache/kafka/blob/e8c70fce26626ed2ab90f2728a45f6e55e907ec1/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java#L779]).



--
This message was sent by Atlassian Jira
(v8.20.10#820010)