hello

  I read the Kafka Client source code .Client do rebalance when receive
JoinGroupResponse  if it is the client leader.if it is not a leader,it
don't rebalance?

when has many Kafka Client and them same groupId,how to do rebalance?

thanks  all.


org.apache.kafka.clients.consumer.internals.AbstractCoordinator.JoinGroupResponseHandler#handle

the code as below :

if (joinResponse.isLeader()) {
    onJoinLeader(joinResponse).chain(future); //do rebalance
} else {
    onJoinFollower().chain(future);//no rebalance
}






-- 
   =============================================

 fuyou001
Best Regards

Reply via email to