[
https://issues.apache.org/jira/browse/KAFKA-16258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans reassigned KAFKA-16258:
--------------------------------------
Assignee: Lianet Magrans
> 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
> Assignee: Lianet Magrans
> Priority: Major
> Labels: kip-848-client-support
> 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 issue is most probably what is causing the failures in the integration
> tests that fail expecting callbacks when the poll interval expires (like
> https://issues.apache.org/jira/browse/KAFKA-16008)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
