Kafka Topic Leader 切换 SOP

Posted 2023-01-22 Hello_哈哈

1. 变更流程

登录 Kafka 客户端。

ssh [e-mail]

新建分区副本重新分配文件，Replicas 放在首位的便为 Leader，如要指定 Leader，指定 Broker ID 即可，以 androidregister_partition2exec.json 为例，将22分区设置为Leader，举例如下：

cd /root/zhaobo/log-kafka
vim androidregister_partition2exec.json

新建json文件举例如下：

    "version": 1,
    "partitions": [
        
            "topic": "androidregister",
            "partition": 1,
            "replicas": [
                22,
                27
            ]
        
    ]

执行以下语句进行 Leader 切换，以 Log Kafka 集群 androidregister Topic为例。

sh /opt/app/kafka/bin/kafka-reassign-partitions.sh --zookeeper 172.16.xx.xx:2181/log-kafka --reassignment-json-file androidregister_partition2exec.json --execute

新建选主 json 文件如下，以 androidregister_partition4leader.json 为例：

    "version":1,
    "partitions":[
        
            "topic":"androidregister",
            "partition":0
        
    ]

执行以下命令，触发选主。

sh /opt/app/kafka/bin/kafka-preferred-replica-election.sh --zookeeper 172.16.xx.xx:2181/log-kafka --path-to-json-file androidregister_partition4leader.json

2. 验证流程

登录 Kafka Manager 界面，查看分区信息，确定 Leader 是否符合预期。

3. 回滚流程
   重复变更流程，将副本中 Broker ID 回滚为原先配置即可。