[
https://issues.apache.org/jira/browse/KAFKA-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zou shengfu updated KAFKA-12169:
--------------------------------
Description:
Background:
Kafka consumer services run with static membership and cooperative rebalance
protocol on kubernetes, and services often restart because of operation. When
we added partitions from 1000 to 2000 for the topic, client leader restart with
unknown member id at the same time, we found the consumers do not tigger
rebalance and still consume 1000 paritions
was:
Background:
Kafka consumer services run on kubernetes, and services often restart because
of operation. When we added partitions from 1000 to 2000 for the topic, client
leader restart with unknown member id at the same time, we found the consumers
do not tigger rebalance and still consume 1000 paritions
> Consumer can not know paritions chage when client leader restart with static
> membership protocol
> ------------------------------------------------------------------------------------------------
>
> Key: KAFKA-12169
> URL: https://issues.apache.org/jira/browse/KAFKA-12169
> Project: Kafka
> Issue Type: Bug
> Components: consumer
> Affects Versions: 2.5.1, 2.6.1
> Reporter: zou shengfu
> Priority: Major
>
> Background:
> Kafka consumer services run with static membership and cooperative rebalance
> protocol on kubernetes, and services often restart because of operation. When
> we added partitions from 1000 to 2000 for the topic, client leader restart
> with unknown member id at the same time, we found the consumers do not
> tigger rebalance and still consume 1000 paritions
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
