kafka 查询机器上有多少leader

kafka 查询机器上有多少leader

在创建一个topic时，kafka尽量将partition均分在所有的brokers上，并且将replicas也j均分在不同的broker上。每个partitiion的所有replicas叫做"assignedreplicas"，"assignedreplicas"中的第一个replicas叫"preferredreplica"，刚创建的topic一般"preferredreplica"是leader。leaderreplica负责所有的读写。但随着时间推移，broker可能会停机，会导致leader迁移，导致机群的负载不均衡。我们期望对topic的leader进行重新负载均衡，让partition选择"preferredreplica"做为leader。对所有Topics进行操作./bin/kafka-preferred-replica-election.sh--zookeeperhadoop16:2181,hadoop17:2181,hadoop18:2181/kafka08对某个Topic进行操作[sankuai@data-kafka01kafka]$cattopicPartitionList.json{"partitions":[{"topic":"test.example","partition":"0"}]}./bin/kafka-preferred-replica-election.sh--zookeeperhadoop16:2181,hadoop17:2181,hadoop18:2181/kafka08--path-to-json-filetopicPartitionList.json

...l.同问

如以上回答内容为低俗、色情、不良、暴力、侵权、涉及违法等信息，可以点下面链接进行举报！

点此我要举报以上问答信息