kafka在所有broker中选出一个controller,所有Partition的Leader选举都由controller决定。controller会将Leader的改变直接通过RPC的方式(比Zookeeper Queue的方式更高效)通知需为此作出响应的Broker。同时controller也负责增删Topic以及Replica的重新分配。kafka在所有broker中选出一个controller,所有Partition的Leade 你的当前访问异常,请进行认证后继续阅读剩余内容。 提交