【kafka】kafka 0.10以及1.x版本的kafka topic 分區擴容

文章目錄

• 1.概述
• • 1.1 replicaAssignmentStr為空
  • 1.2 指定副本

1.概述

因為需要是以需要一個程式對kafka進行擴容處理

然後寫了一個方法如下

/**
     *
     * @param zkUrl
     * @param topicName
     * @param partition
     * @param replicaAssignmentStr
     *      副本配置設定方案為格式 "2:1,3:1" 這裡表示的是2個分區分别對應的副本情況，0分區對應的brokerid為
     *      2 和 1 的，1分區對應的副本為 3，1 不同的分區的副本用逗号分隔，同一個分區的多個副本之間用冒号
     *      分隔，同時需要注意的是，副本配置設定方案要報考已有分區的副本配置設定資訊根據配置設定順序從左到右依次與分區對應
     *