为什么发送给Topic的消息在分区中分布不均衡?
更新时间 2024-01-05 15:51:25
最近更新时间: 2024-01-05 15:51:25
本节介绍Kafka 发送给Topic的消息在分区中分布不均衡原因
问题现象
发送消息到某个Topic后,该Topic下部分分区消息比较多,部分分区消息少,甚至没有。
可能原因
发送消息时指定了分区,导致未指定的分区没有消息。
发送消息时指定了消息Key,按照对应的Key发送消息至对应的分区,导致分区消息不均衡。
通过代码重新实现了分区分配策略,但策略逻辑有问题,导致分区消息不均衡。