[ 
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)

Reply via email to