說明修改(gai)分區數,不會影(ying)響業務(wu)。
修改Topic分(fen)區(qu)數的方法(fa)如下:
- 方法1:在控制臺修改
- 方法2:在Kafka Manager上修改
- 方式3:在Kafka客戶端上修改
方法1:在控制臺修改
步驟 1 登錄管理(li)控制臺。
步驟 2 在管理控制臺右上角單擊
,選擇區域。
說明請選擇Kafka實例所在的區域。
步驟 3 在管理控制臺左上角單擊
,選擇(ze)“企業中間(jian)件”-“分布(bu)式消息服務”-“Kafka專享版”,進入分布(bu)式消息服務Kafka專享版頁面(mian)。
步(bu)驟(zou) 4 單擊Kafka實(shi)例的(de)名稱,進入(ru)實(shi)例詳情頁面。
步驟(zou) 5 選(xuan)擇“Topic管理(li)”頁簽,顯示已創(chuang)建的Topic詳情。
步(bu)驟 6 通過以下任意一種方法,修改Topic分(fen)區數。
- 勾選Topic名稱左側的方框,可選一個或多個,單擊信息欄左上側的“編輯Topic”。
- 在待修改分區數的Topic所在行,單擊“編輯”。
步驟 7 在“編輯Topic”對話框中,輸入分區數,單擊“確定”。
說明分區數只支持增加,不支持減少。
出于性能考慮,Kafka控制臺限定單個Topic的分區數上限為100。
所有Topic分區數總和不能超過實例允許的分區上限。
方法2:在Kafka Manager上修改
步驟(zou) 1 登錄(lu)Kafka Manager。
步驟 2 在(zai)Kafka Manager中,單(dan)擊“Topic > List”,進入Topic列表界面(mian)。
步驟 3 單擊Topic名稱,進入Topic詳情界面。
步驟 4 單擊“Add Partitions”,進入增加分區界面。
圖 Topic詳情界面(mian)


步驟 5 輸入分(fen)區(qu)數,單擊“Add Partitions”。
圖 增加分區數量


顯示“Done”,表示分區(qu)增加成(cheng)功。
圖分區增加成功



說明分區數只支持增加,不支持減少。
所有Topic分區數總(zong)和不能(neng)超(chao)過實例允許的分區上限。
方式3:在Kafka客戶端上修改
Kafka客戶端版本為2.2以上時,支持通過kafka-topics.sh修(xiu)改(gai)Topic分區(qu)數(shu)。
- 未開啟SASL的Kafka實例,在“/{命令行工具所在目錄}/kafka_{version}/bin/”目錄下,通過以下命令修改Topic分區數。
./kafka-topics.sh --bootstrap-server {broker_ip}:{port} --topic {topic_name} --alter --partitions {partition_num}
- 已開啟SASL的Kafka實例,通過以下步驟修改Topic分區數。
- (可選)如果已經設置了SSL證書配置,請跳過此步驟。否則請執行以下操作。在Kafka客戶端的“/config”目錄中創建“ssl-user-config.properties”文件,參考步驟3增加SSL證書配置。
- 在“/{命令行工具所在目錄}/kafka_{version}/bin/”目錄下,通過以下命令修改Topic分區數。
./kafka-topics.sh --bootstrap-server {broker_ip}:{port} --topic {topic_name} --alter --partitions {partition_num} --command-config ./config/ssl-user-config.properties