java - 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 扩展(版本 4.0-M2)的当前实现在事件处理方面不支持设置重试策略。

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