文档首页/ 分布式消息服务Kafka版/ 常见问题/ 消息问题/ 为什么生产的消息全部进入同一个分区？
更新时间：2026-01-12 GMT+08:00
查看PDF
分享

为什么生产的消息全部进入同一个分区？

可能原因

  • 生产者发送消息时指定了相同Key，相同Key的消息会被路由至同一个分区。
  • 生产者使用自定义的Key序列化器，即便发送的消息携带不同的Key或无Key，只要服务端经过该Key序列化器解析出相同的Key，最终会导致消息被路由至同一个分区。

解决方法

  • 生产者发送消息时设置不同的Key。
  • 基于实际问题，优化自定义Key序列化器的处理逻辑。
父主题： 消息问题

相关文档