Event Hub Listener - получите все сообщения за один раз

Question

Я тестирую концентратор событий.Разработчики отправляют сообщения в Event Hub.Я построил Event Hub Listener, чтобы проверить, все ли сообщения отправляются / принимаются правильно.Вот дизайн, который я использовал:

https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-dotnet-framework-getstarted-receive-eph

Проблема, с которой я столкнулся, - это около 4 миллионов событий в концентраторе событий, и метод ProcessEventsAsync вызывается 4 или 5 раз, изатем перестает звонить.

Есть ли способ, который я могу просто попросить, чтобы получать только сообщения, добавленные за последние X минут?

Answer 1

Вместо использования EventProcessorHost вы можете напрямую прочитать все события.Это означает, что вы будете вызывать метод Receive напрямую для чтения пакета событий.

См. Прямой потребитель и Концентраторы событий шины обслуживания Прямые получатели для примеров кода.

Нет способа отфильтровать события по времени (последние X секунд), смещения являются единственным адресуемым пространством.