CQRS - 重新发布事件

Question

我们有一个 CQRS 项目，并且正在考虑一种实现“追赶”的方法，例如一个新的事件处理程序被启动并告诉事件存储为他重播所有事件。

我们不确定是否应该通过 NServiceBus 进行回放，因为存在真正的 1:1 连接并且没有发布/订阅情况。此外，我们认为我们的新消费者无法跟上发布速度，并且其输入队列会卡住。

这里的最佳做法是什么？

Answer 1

我听说有人这样做：

1. 拥有重播/重播事件的系统。产生已经看到这些事件的投影的事件处理程序会忽略这些事件。
2. 在重置事件或从头开始新的投影时，允许事件处理程序直接查询事件。这可以在某些系统中通过直接从事件存储中读取来完成，而在其他基于参与者的系统中，可以查询围绕事件源的参与者抽象。

据我了解，选项 2 可以提高性能，因为可以批量查询事件，而不是单独重播给所有侦听器。这些只是我的观察，还没有任何实际经验可供借鉴。