消息能够被发送,但是不能够被消费

某天,在我们的生产环境中突然发现消息无法被消费了。于是我们在pulsar-admin中查看了消费阻塞的情况:


发现不同分区的消费并不均匀,导致有些分区消息积压的非常厉害。
然后,我们去看了下资源的消耗情况,发现有几个IO线程消耗了大量的资源。线程名称如下:

  • pulsar-io-5-*
  • BookeeperClient*
  • broker-topic-worker*

最后无奈只能重启,重启后消息能够被消费,但是一段时间之后,又出现了上面的情况。
Github中有一个Issue描述了类似的问题:

可以提供下下topics Stats 和 stats-Internal。