南南北北

低版本(modifyThrottleTaskByZKClient)执行后导致限流丢失follower.replication.throttled.replicas

1

###问题代码段 ``` // 当前ZK上的迁移信息 scala.collection.Map currentParts = kafkaZkClient.getReplicaAssignmentForTopics( proposedParts.keySet().map(elem -> elem.topic()).toSet() ); // 转为moveMap格式 scala.collection.mutable.Map moveMap = ReassignPartitionsCommand.calculateProposedMoveMap(new scala.collection.mutable.HashMap(), proposedParts, currentParts); // 对Topic进行限流 scala.collection.Map leaderThrottles = ReassignPartitionsCommand.calculateLeaderThrottles(moveMap); scala.collection.Map followerThrottles =...

希望调度系统zeus开源。