Axon4 - 重新排队失败消息

Question

在下面的场景中，Axon 的行为是什么 -

• 命令总线收到命令
• 它创建了一个事件
• 但是消息传递基础设施出现故障（比如 kafka）

Axon 是否具有事件重新排队功能或任何其他替代方案来处理这种情况。

Answer 1

如果您使用的是 Axon，您就会知道它区分命令、事件和查询消息。我建议在你的问题中具体说明你想重试哪种消息类型。

但是，我假设它是关于事件的，就像你说的卡夫卡一样。 如果是这种情况，我强烈建议您阅读有关此事的 reference guide，因为它说明了如何将 Kafka 发布与 Axon 中的实际事件存储分离。

简单地说，使用TrackingEventProcessor作为在Kafka上发布事件的方式，因为这将确保使用专用线程进行发布，而不是使用同一个线程存储事件。添加，TrackingEventProcessor 可以重播，因此 "re-process" 事件。