kafka 自定義分割槽分配和遷移
分割槽重新分配工具還可用於選擇性地將分割槽的副本移動到特定的代理集。當以這種方式使用時,假設使用者知道重新分配計劃並且不需要工具生成候選重新分配,有效地跳過 - 生成步驟並直接移動到--execute步驟
例如,以下示例將主題foo1的分割槽0移動到代理5,6,將主題foo2的分割槽1移動到代理2,3:
第一步是在json檔案中手工製作自定義重新分配計劃:
1 2 |
|
然後,使用帶有--execute選項的json檔案來啟動重新分配過程:
1 2 3 4 五 6 7 8 9 10 11 12 13 14 |
|
--verify選項可與該工具一起使用,以檢查分割槽重新分配的狀態。請注意,相同的expand-cluster-reassignment.json(與--execute選項一起使用)應與--verify選項一起使用:
1 2 3 4 |
|
增加現有分割槽的複製因子很容易。只需在自定義重新分配json檔案中指定額外副本,並將其與--execute選項一起使用,以增加指定分割槽的複製因子。
例如,以下示例將主題foo的分割槽0的複製因子從1增加到3.在增加複製因子之前,分割槽的唯一副本存在於代理5上。作為增加複製因子的一部分,我們將新增更多副本經紀人6和7。
第一步是在json檔案中手工製作自定義重新分配計劃:
1 2 3 |
|
然後,使用帶有--execute選項的json檔案來啟動重新分配過程:
1 2 3 4 五 6 7 8 9 10 |
|
--verify選項可與該工具一起使用,以檢查分割槽重新分配的狀態。請注意,相同的increase-replication-factor.json(與--execute選項一起使用)應與--verify選項一起使用:
1 2 3 |
|
您還可以使用kafka-topics工具驗證複製因子的增加:
1 2 3 |
|