我通过 Java EventHubClient 从 Azure EventHub 实例进行消费执行。我的策略是创建并坚持 PartitionReceiver对于每个分区并调用 PartitionReceiver::receiveSync定期。
EventHub 实例已将分区计数增加到 30+,相同的逻辑现在抛出 QuotaExceededException ,看起来我们已经达到了消费者组的最大接收者限制。
这让我觉得我的策略完全错误,在不超过此配额的情况下不断从 EventHub 实例的所有分区进行消费的标准化方法是什么?
谢谢!
最佳答案
接收器的最大数量限制为 5,并且针对每个消费者组的每个分区。您应该检查您的代码并确定为什么要在至少一个分区上创建 5 个以上的接收器。
顺便说一句,您应该使用 EventProcessorHost 来实现您的消费者如果您没有充分的理由使用 EventHubClient。
关于azure - 从分区事件中心消费以避免 QuotaExceededException 的正确策略是什么?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/61390002/