Kafka 分區重分配源碼分析

上一篇跟大家描述了 Kafka 集羣擴容的方案與過程,這次就跟大家詳細描述 Kafka 分區重分配的實現細節。 Kafka 爲用戶提供了分區重分配的執行腳本 kafka-reassign-partitions.sh,腳本內容如下: ReassignPartitionsCommand 類爲我們提供了分區重分配的功能,主要有如下方法: generateAssignment() 函數:對應執行腳本的 -
相關文章
相關標籤/搜索