問題現(xiàn)象

發(fā)送消息到某個Topic后,該Topic下部分分區(qū)消息比較多,部分分區(qū)消息少,甚至沒有。

分區(qū)中消息量可以在Topic詳情頁面的分區(qū)狀態(tài)頁簽查看,位點數(shù)即是消息數(shù)。以下圖為例,分區(qū)2消息比較多,其他分區(qū)消息少甚至沒有,消息分布不均衡。分區(qū)消息分布不均衡

可能原因

  • 發(fā)送消息時指定了分區(qū),導(dǎo)致未指定的分區(qū)沒有消息。
  • 發(fā)送消息時指定了消息Key,按照對應(yīng)的Key發(fā)送消息至對應(yīng)的分區(qū),導(dǎo)致分區(qū)消息不均衡。
  • 通過代碼重新實現(xiàn)了分區(qū)分配策略,但策略邏輯有問題,導(dǎo)致分區(qū)消息不均衡。