kafka分割槽重新分配

2021-10-09 16:52:34 字數 771 閱讀 3827

擴容kafka之後,針對擴容之前的topic進行重新平衡leader,replicas,isr

1.生成分配計畫

新建乙個json檔案,內容如下:(topic為要修改的topic)這裡檔案取名為

topics-to-move.json

],「version」: 1

}使用kafka-reassign-partitions.sh命令生成乙個分配計畫,下面的命令列中broker-list引數即對應brokerid

命令如下:

bin/kafka-reassign-partitions.sh --zookeeper zk01.td.com:2181

–topics-to-move-json-file topics-to-move.json

–broker-list 「1,2」

–generate

結果入下圖,生成了兩條資訊,第一條為現在的分配情況,第二條為計畫更改的內容

把計畫修改的結果複製,放在第二個json檔案中,這裡取名為reassignment.json

2.執行分配計畫

執行kafka-reassign-partition.sh命令根據上述執行計畫生成的結果進行分配,命令如下:

bin/kafka-reassign-partitions.sh

–zookeeper zk01.td.com:2181

–reassignment-json-file reassignment.json

–execute

檢視topic,已經重新分配

linux 重新讀取磁碟 linux重新分配磁碟

今天,我看了我的linux的磁碟,發現 home目錄這個下面有太多空間,而我的根目錄下面又太少了,所以,我把 home目錄下面的空間分配給根目錄下面,命令如下 檢視磁碟容量 df h 解除安裝磁碟 umount home 將磁碟重新分配給10g,以前是47g 讓上買麵的操作生效 掛在磁碟 mount...

CentOS7 重新分配分割槽大小的實現方法

昨天幫人裝了個系統忘了手滑點了自動分割槽,自動分的大小是很無語的不適合日常使用。執行命令 df h 可以看到系統自動把剩餘的空間全部分配到home分割槽下,但是我們一般myzgmlqpr使用的是root分www.cppcns.com區下的空間,所以必須得把home下的多於空間挪到root下 首先你需...

kafka的分割槽分配策略

將所有broker n個 和partition排序 將第i個partition分配到第 i mode n 個broker上 當key為空時,訊息隨機傳送到各個分割槽 各個版本會有不同,有的是採用輪詢的方式,有的是隨機,有的是一定時間內只傳送給固定partition,隔一段時間後隨機換乙個 用key的...