引流方式

原理

影響

適用場景

持續時間

新增分區

為原集群節點上的所有Topic在擴容后的新節點中增加分區。

• 分區消息亂序。

• 分區數量改變。如果您的客戶端無法自動感知到新分區（例如：指定分區發送消費以及一些數據處理場景），您可能需要重啟或者修改客戶端代碼。

• 不要求分區順序。

• 不指定分區發送。

• 消費方式采取訂閱。

秒級。

遷移分區（推薦）

• Local存儲：使用kafka-reassign-partitions工具遷移分區數據。

• 云存儲：修改映射關系，不遷移分區數據。

• Local存儲：臨時性的內部流量。

• 云存儲：無臨時性的內部流量。

任何集群擴容場景。

• Local存儲：分鐘級或小時級。取決于要遷移的Local存儲數據量。如果數據量較大，可能持續幾小時甚至更久，您需要謹慎評估。建議您在業務流量低峰期執行遷移操作。

• 云存儲：秒級。遷移1個Topic大約需要30秒。

不引流（不推薦）

不進行任何操作，即原有的Topic依舊分布在擴容前的集群節點上，新增的Topic均衡分布到擴容后的所有集群節點上。

• 原有的Topic峰值流量會受限于擴容前的流量規格。

• 如果原有的Topic流量較大，可能會出現集群節點之間流量不均衡。

• 原有的Topic流量非常小，并且集群擴容后原有的Topic流量沒有較大提升。

• 集群擴容后會新建Topic，并且絕大部分流量會打在新建的Topic上。

立即生效。