Почему EventProcessorHost не пересылает сбойные сообщения после истечения срока их аренды?
У меня проблема с обработкой сообщений. В моем случае у меня есть два EPH, каждый из которых работает в отдельном док-контейнере. Первый контейнер с EPH1 аварийно завершает работу (из-за неправильной конфигурации) и генерирует исключения (я ловлю и перекидываю исключения в OnEvent). Тогда секундный контейнер, который работает с EPH2, никогда не будет выбирать сообщения с ошибками из первого контейнера. Буду очень признателен, если кто-нибудь сможет мне помочь с этим вопросом.
@Override
public void onEvents(PartitionContext context, Iterable<EventData> events) throws Exception {
int eventCount = 0;
for (EventData data : events) {
try {
//only throwing this exception to show how my OnEvent is implemented this not an actual working code
throw new Exception("failed the batch from partition" + context.getPartitionId());
eventCount++;
} catch (Exception e) {
throw e;
}
}
context.checkpoint().get();
}
Я ожидаю увидеть сообщения, которые не удалось обработать EPH2
так как они не были контрольно-пропускными пунктами.