Почему 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 так как они не были контрольно-пропускными пунктами.

0 ответов

Другие вопросы по тегам