為什么發送給Topic的消息在分區中分布不均衡?
更新時間 2024-01-05 15:51:25
最近更新時間: 2024-01-05 15:51:25
分享文章
本節介紹Kafka 發送給Topic的消息在分區中分布不均衡原因
問題現象
發送消息到某個Topic后,該Topic下部分分區消息比較多,部分分區消息少,甚至沒有。
可能原因
發送消息時指定了分區,導致未指定的分區沒有消息。
發送消息時指定了消息Key,按照對應的Key發送消息至對應的分區,導致分區消息不均衡。
通過代碼重新實現了分區分配策略,但策略邏輯有問題,導致分區消息不均衡。