擴容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的...