Axon Config - политика повторных попыток Kafka после исключения @eventhandlers - PullRequest
0 голосов
/ 09 апреля 2020

Я начал использовать Axon 4.3.1 (последняя версия) в своем проекте и у меня возникла проблема.

Где я могу настроить политики повторов kafka после того, как @eventhandler выдает исключение?

OBS: я использую SubscribeingEventProcessor тип в качестве обработчика событий (оба проекта). Я использую отдельные проекты! Модель команд использует события mon go и publi sh на Kafka. Модель запроса потребляет события из Кафки (eventbus). Таким образом, при использовании отдельных JVM.

@ processinggroup (обработчик событий) настраивается на класс с методом обработчика событий. Я хотел бы иметь конфигурацию для автоматической повторной попытки Kafka через некоторое время в случаях ошибок (из проекта модели запросов).

Могу ли я использовать какой-нибудь компонент Axon по умолчанию? Могу ли я использовать что-то вроде Spring-Retry или внутренних настроек Kafka?

Я нашел что-то подобное (документация):

https://docs.axoniq.io/reference-guide/configuring-infrastructure-components/event-processing/event-processors#error -обработка

"Основываясь на предоставленном объекте ErrorContext, вы можете решить игнорировать ошибку, запланировать повторные попытки , выполнить доставку по очереди недоставленных сообщений или повторно выбросить исключение."

Как можно Я настраиваю (например, расписание повторов ) на @eventhandler после ошибок?

Не могли бы вы мне помочь?

Спасибо.

1 Ответ

0 голосов
/ 10 апреля 2020

Текущая реализация Axon Kafka Extension (версия 4.0-M2) не поддерживает настройку политики повторных попыток, когда дело доходит до обработки событий.

Я бы сказал, что сейчас ваш лучший подход - это что-то настроить так на Кафке, если это вообще возможно. В противном случае, принудительное воспроизведение событий через Кафку будет вашим лучшим подходом.

...