[ https://issues.apache.org/jira/browse/KAFKA-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17287357#comment-17287357 ]
Boyang Chen commented on KAFKA-12169: ------------------------------------- [~guozhang] One question regarding T1, when we receive the assignment, do we validate its total partitions against our own metadata? If so, the leader should attempt a rejoin IMHO. > Consumer can not know paritions change 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 > Labels: bug > > 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)