Axon Config - @eventhandlers 抛出异常后的 Kafka 重试策略

Question

我已经开始在我的项目中使用 Axon 4.3.1（最新版本）并且遇到了问题。

@eventhandler 抛出异常后，我在哪里可以配置 kafka 重试策略？

OBS：我使用 SubscribingEventProcessor 类型作为事件处理器（两个项目）。我正在使用单独的项目！命令模型使用 mongo 并在 Kafka 上发布事件。查询模型使用来自 Kafka (eventbus) 的事件。这样，使用单独的 JVM。

@processinggroup(event-processor) 配置为使用事件处理程序方法进行分类。在错误情况下（来自查询模型项目）一段时间后，我想对 Kafka 自动重试进行配置。

我可以使用一些默认的 Axon 组件吗？我可以使用 spring-retry 或内部 kafka 配置本身吗？

我发现了类似的东西（文档）：

https://docs.axoniq.io/reference-guide/configuring-infrastructure-components/event-processing/event-processors#error-handling

“根据提供的 ErrorContext 对象，您可以决定忽略错误、安排重试、执行死信队列传递或重新抛出异常。”

错误后如何在@eventhandler 上进行配置（例如，安排重试）？

你能帮帮我吗？

谢谢。

Answer 1

Axon 的 Kafka Extension（4.0-M2 版本）的当前实现不支持在事件处理方面设置重试策略。

我认为你现在最好的方法是在 Kafka 上设置类似的东西，如果可能的话。否则，通过 Kafka 强制重播事件将是您最好的方法。