文章目录

kafka-leader-election Leader重新选举

More

日常运维 、问题排查 怎么能够少了滴滴开源的

滴滴开源LogiKM一站式Kafka监控与管控平台

kafka-leader-election Leader重新选举

1 指定Topic指定分区用重新PREFERRED：优先副本策略 进行Leader重选举

> sh bin/kafka-leader-election.sh --bootstrap-server xxxx:9090 --topic test_create_topic4 --election-type PREFERRED --partition 0

2 所有Topic所有分区用重新PREFERRED：优先副本策略 进行Leader重选举

sh bin/kafka-leader-election.sh --bootstrap-server xxxx:9090 --election-type preferred  --all-topic-partitions

3 设置配置文件批量指定topic和分区进行Leader重选举

先配置leader-election.json文件

{
  "partitions": [
    {
      "topic": "test_create_topic4",
      "partition": 1
    },
    {
      "topic": "test_create_topic4",
      "partition": 2
    }
  ]
}

 sh bin/kafka-leader-election.sh --bootstrap-server xxx:9090 --election-type preferred  --path-to-json-file config/leader-election.json
 

相关可选参数

参数 描述 例子

--bootstrap-server 指定kafka服务 指定连接到的kafka服务 –bootstrap-server localhost:9092

--topic 指定Topic，此参数跟--all-topic-partitions和path-to-json-file 三者互斥

--partition 指定分区,跟--topic搭配使用

--election-type 两个选举策略(PREFERRED:优先副本选举,如果第一个副本不在线的话会失败;UNCLEAN: 策略)

--all-topic-partitions 所有topic所有分区执行Leader重选举; 此参数跟--topic和path-to-json-file 三者互斥

--path-to-json-file 配置文件批量选举，此参数跟--topic和all-topic-partitions 三者互斥

More

Kafka专栏持续更新中…(源码、原理、实战、运维、视频、面试视频)