今年DDD eXchange的演讲是我在事件驱动/ CQRS系统中遇到的流程管理器/ Saga模式的最佳资源: https://skillsmatter.com/skillscasts/9853-long-running-processes-in-ddd (需要注册免费帐户才能查看)
那里显示的演示存在于github上: https://github.com/flowing/flowing-retail
我给它一个旋转,我非常喜欢它。我建议先观看视频来设置舞台。
尽管所示方法与消息总线无关,但该演示使用Kafka为进程管理器发送命令并侦听来自其他有界上下文的事件。它不使用Kafka Streams,但我不明白为什么它不能插入Kafka Streams拓扑并成为更广泛的架构的一部分,就像你引用的Commander演示文稿中描述的那样。
我希望能够根据自己的需要对此进行进一步调查,所以请随时在Kafka用户邮件列表上创建一个帖子,这是一个合作这些模式的好地方。
希望有所帮助:-)