【发布时间】:2016-09-17 15:07:57
【问题描述】:
所以我使用 EventHubs 进行数据管道队列,但为了获得缓冲摄取的好处,我需要知道任何时候一个分区中有多少项。根据消费者组和分区 ID,这可以深入了解哪些接收器需要扩展或未按预期执行。
我知道您可以根据消息数量创建警报,但我真正想要的是能够从我的内部请求给定命名空间、EventHub、消费者组或分区(无论可用)的当前项目计数C# 代码。
我可以看到您可以使用 .NET ServiceBus API 轻松获取队列大小(以字节为单位),但我看不到任何获取项目计数的方法?
【问题讨论】:
-
听起来您实际上要求的是一种告诉消费者各种分区滞后的方法(或者至少这是人们通常需要的)。那就是“每个分区中给定的消费者有多少物品”。我建议围绕这个问题提出另一个问题,尽管我还没有写出非常必要的代码。使用 Apache Kafka 进行监控是很常见的事情。
标签: c# azure azureservicebus azure-eventhub