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

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

            ]

        }

    ]

}

Thu Feb 21 16:56:13 CST 2019