[
https://issues.apache.org/jira/browse/KAFKA-20641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sanghyeok An updated KAFKA-20641:
---------------------------------
Description:
When a static ConsumerGroup member temporarily leaves with
LEAVE_GROUP_STATIC_MEMBER_EPOCH (-2), consumerGroupStaticMemberGroupLeave
clears pending revocations but leaves UNREVOKED_PARTITIONS state unchanged.
ConsumerGroup should match StreamsGroup semantics by treating unrevoked
partitions as revoked and transitioning the member back to STABLE.
More details are available here
https://github.com/apache/kafka/pull/22245#discussion_r3323708342
was:
When a static ConsumerGroup member temporarily leaves with
LEAVE_GROUP_STATIC_MEMBER_EPOCH (-2),
consumerGroupStaticMemberGroupLeave clears pending revocations but leaves
UNREVOKED_PARTITIONS state unchanged.
ConsumerGroup should match StreamsGroup semantics by treating unrevoked
partitions as revoked and transitioning the member back to
STABLE.
> ConsumerGroup should clean up the state when a static member temporarily
> leaves
> -------------------------------------------------------------------------------
>
> Key: KAFKA-20641
> URL: https://issues.apache.org/jira/browse/KAFKA-20641
> Project: Kafka
> Issue Type: Improvement
> Reporter: sanghyeok An
> Assignee: sanghyeok An
> Priority: Minor
>
> When a static ConsumerGroup member temporarily leaves with
> LEAVE_GROUP_STATIC_MEMBER_EPOCH (-2), consumerGroupStaticMemberGroupLeave
> clears pending revocations but leaves UNREVOKED_PARTITIONS state unchanged.
> ConsumerGroup should match StreamsGroup semantics by treating unrevoked
> partitions as revoked and transitioning the member back to STABLE.
> More details are available here
> https://github.com/apache/kafka/pull/22245#discussion_r3323708342
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
