axon config-kafka@eventhandlers抛出异常后重试策略

fdx2calv  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(370)

我开始在我的项目中使用Axon4.3.1(最新版本),但遇到了一个问题。
@eventhandler抛出异常后,在哪里可以配置kafka重试策略?
obs:我使用subscribingeventprocessor类型作为事件处理器(两个项目)。我在使用不同的项目!命令模型使用mongo并在kafka上发布事件。查询模型使用来自kafka(eventbus)的事件。这样,就可以使用单独的jvm。
@processinggroup(事件处理器)配置为使用事件处理程序方法初始化。我想有一个配置Kafka自动重试一段时间后,在错误的情况下(从查询模型项目)。
我可以使用一些默认的轴突组件吗?我可以使用类似spring重试或内部kafka配置本身的东西吗?
我发现了类似的东西(文档):
https://docs.axoniq.io/reference-guide/configuring-infrastructure-components/event-processing/event-processors#error-处理
根据提供的errorcontext对象,您可以决定忽略错误、计划重试、执行死信队列传递或重新引发异常
出错后如何在@eventhandler上配置(例如,计划重试)?
你能帮我吗?
谢谢。

3ks5zfa0

3ks5zfa01#

axon的kafka扩展(版本4.0-m2)的当前实现不支持在事件处理方面设置重试策略。
我认为你现在最好的办法就是在Kafka身上设置这样的东西,如果可能的话。否则,通过Kafka强制重播事件将是最好的方法。

相关问题