Я начал использовать 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 после ошибок?
Не могли бы вы мне помочь?
Спасибо.