【kafka运维】Leader重新选举运维脚本-CFANZ编程社区

文章目录

kafka-leader-election Leader重新选举
More

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` 三者互斥