文档首页/ 分布式消息服务Kafka版/ 常见问题/ Topic和分区问题/ Topic扩容分区后,新分区消息持续堆积,无消费者进行消费?
更新时间:2025-12-09 GMT+08:00
分享

Topic扩容分区后,新分区消息持续堆积,无消费者进行消费?

可能原因

若消费端采用librdkafka客户端,此问题为该客户端的已知Bug。具体内容为:Topic扩容分区后,若消费组内的leader消费者并未订阅该Topic,那么新扩容的分区将无法被该消费组订阅。

解决办法

  • 消费组仅订阅一个Topic,可避免该问题发生。
  • Topic扩容分区后,重启消费组内的任意一个消费者进程,触发消费组重平衡,使新分区被重新分配。
  • Topic扩容分区后,增加消费者数量,触发消费组重平衡,使新分区被重新分配。

相关文档