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