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)
