使用 Apache Pulsar 作为分布式任务队列时如何获取排队的任务（尚未消费的消息）？

Question

我目前正在评估 Apache Pulsar 对于使用“共享”订阅构建分布式任务队列的适用性。

一个必需的功能是获取某些主题的所有排队任务，或者至少获取排队任务的数量。我的意思是指订阅消费者尚未收到的给定订阅的所有消息。 这可能吗？如果可以，如何实现？

Answer 1

您可以通过管理 API 请求订阅的统计数据 https://pulsar.apache.org/docs/next/administration-stats/#subscription-stats -

msgBacklog

值应该会为您提供您正在寻找的内容。