[
https://issues.apache.org/jira/browse/KAFKA-16258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16258:
-----------------------------------
Description:
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)
was: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]).
> 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
> Priority: Major
> 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)
