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