kafkakafka 2.3 版本的kafka topic 分区扩容

Posted 2021-12-31 九师兄

文章目录

• 1.概述
• 2 .AdminZkClient扩容

1.概述

首先参考文章：【kafka】kafka 0.10以及1.x版本的kafka topic 分区扩容

因为需要所以需要一个程序对kafka进行扩容处理

然后写了一个方法如下

    /**
     * 添加主分区
     * @param zkUrl
     * @param topicName
     * @param partition
     * @param replcation
     * @return
     */
    public static boolean addPartition