更新时间:2025-12-09 GMT+08:00
Topic扩容分区后,新分区消息持续堆积,无消费者进行消费?
可能原因
若消费端采用librdkafka客户端,此问题为该客户端的已知Bug。具体内容为:Topic扩容分区后,若消费组内的leader消费者并未订阅该Topic,那么新扩容的分区将无法被该消费组订阅。
解决办法
- 消费组仅订阅一个Topic,可避免该问题发生。
- Topic扩容分区后,重启消费组内的任意一个消费者进程,触发消费组重平衡,使新分区被重新分配。
- Topic扩容分区后,增加消费者数量,触发消费组重平衡,使新分区被重新分配。
父主题: Topic和分区问题