论坛 › Web技术 › kafka修改topic分区数和副本集数

土小帽 发表于 2023-11-3 20:05:08

kafka修改topic分区数和副本集数

修改分区数
/usr/local/kafka/bin/kafka-topics.sh --alter --zookeeper 10.1.1.1:2181/kafka --topic hogtmoperation --partitions 5
修改副本集数
/usr/local/kafka/bin/kafka-reassign-partitions.sh -zookeeper 10.1.1.1:2181/kafka --reassignment-json-file /root/replication.json --execute

其中/root/replication.json文件如下：
{
    "version": 1,
    "partitions": [
      {
            "topic": "hogtmoperation",
            "partition": 0,
            "replicas": [
                2,
                1
            ]
      },
   {
            "topic": "hogtmoperation",
            "partition": 1,
            "replicas": [
                3,
                2
            ]
      },
   {
            "topic": "hogtmoperation",
            "partition": 2,
            "replicas": [
                4,
                3
            ]
      },
   {
            "topic": "hogtmoperation",
            "partition": 3,
            "replicas": [
                5,
                4
            ]
      },
   {
            "topic": "hogtmoperation",
            "partition": 4,
            "replicas": [
                6,
                5
            ]
      }
    ]
}

查看完整版本: kafka修改topic分区数和副本集数