用Kafka实施Sagas

Question

我正在使用Kafka进行事件采购，并且我对使用Kafka实现sagas感兴趣。我做了一些研究，但找不到任何关于该主题的信息。关于Sagas的信息很多，但我觉得使用Kafka的实现可能涉及多个复杂问题。有关如何执行此操作的最佳做​​法？这里提到的Commander模式似乎与我要构建的体系结构很接近，但是在演示文稿的任何地方都没有提到sagas。

Answer 1

我今年DDD eXchange的演讲是我在事件驱动/ CQRS系统中遇到wrt Process Manager / Saga模式的最佳资源：https ://skillsmatter.com/skillscasts/9853-long-running-processes-in-ddd （需要注册一个免费帐户才能查看）

此处显示的演示位于github：https：//github.com/flowing/flowing-retail

我试了一下，我很喜欢。我建议您先观看视频以准备好舞台。

尽管显示的方法与消息总线无关，但是该演示使用Kafka作为Process Manager来向其他有界上下文发送命令并侦听来自其他有界上下文的事件。它不使用Kafka Streams，但我不明白为什么不能将其插入Kafka Streams拓扑结构并成为更广泛的体系结构的一部分，就像您所引用的Commander演示中所描述的那样。

我希望根据我们自己的需要对此进行进一步的调查，因此请随时在Kafka用户邮件列表上启动一个线程，这是在此类模式下进行协作的好地方。

希望有帮助:-)