cqrs - 使用 Kafka 作为 (CQRS) 事件存储。好主意？

Question

虽然我遇到过Kafka之前，我最近才意识到 Kafka 可能可以用作 CQRS 的(基础) , eventstore .

Kafka支持的要点之一:

• 事件捕获/存储，当然都是 HA。
• 发布/订阅架构
• 能够重播事件日志，从而使新订阅者能够在事后向系统注册。

诚然，我并不是 100% 精通 CQRS/事件溯源，但这似乎非常接近事件应该发生的情况。有趣的是:我真的找不到太多关于 Kafka 被用作事件存储的信息，所以也许我错过了一些东西。

那么，Kafka 是否还缺少什么才能成为一个好的事件存储呢？会起作用吗？使用其生产的？对见解、链接等感兴趣？

基本上，系统的状态是根据系统曾经接收到的事务/事件来保存的，而不是通常所做的那样仅保存系统的当前状态/快照。 (将其视为会计中的总账:所有交易最终都会加起来达到最终状态)这允许各种很酷的事情，但只需阅读提供的链接即可。

Answer 1

我是Kafka的原作者之一。 Kafka 作为事件溯源日志可以很好地工作。它具有容错能力，可扩展到巨大的数据大小，并具有内置的分区模型。

我们在 LinkedIn 中将其用于这种形式的多个用例。例如，我们的开源流处理系统 Apache Samza 附带 built-in support用于事件源。

我认为您很少听说过使用 Kafka 进行事件溯源，主要是因为事件溯源术语在 Kafka 最受欢迎的消费者网络空间中似乎并不流行。

我写了一些关于这种 Kafka 用法的文章 here .