Смещение концентратора событий Azure

Question

Я реализовал код по ссылке ниже для получения событий из концентратора событий. Но скажем, что есть 10 событий, и контрольные точки сделаны для каждых 5 событий. Теперь программа аварийно завершает работу при чтении 7-го события, и если я перезапускаю хост процессора событий, то события (1,2,3,4,6) перечитываются. Подскажите, пожалуйста, как мне снова избежать перечитывания и чтения с 7-го события? Любой пример будет оценен. Благодарю.

https://github.com/Azure/azure-event-hubs/blob/master/samples/Java/src/main/java/com/microsoft/azure/eventhubs/samples/Basic/EventProcessorSample.java

Answer 1

Что ж, в контексте концентратора событий ваша задача - справиться с возможным дублированием сообщений, поскольку концентратор событий гарантирует хотя бы один раз доставки, см.

Гарантирует ли Azure Event Hub хотя бы раз доставку?

Мы не знаем ваш сценарий, поэтому мы не можем предложить что-то кроме вас для создания механизма обнаружения дублирующихся сообщений. Например, добавление уникального идентификатора к данным перед отправкой их в концентратор событий и проверка обработчиком на соответствие списку обработанных сообщений.