使用 kafka 作为事件存储来补充事件源聚合

Question

越来越多的文章谈论 kafka 作为事件存储并在使用 cqrs 和事件源构建的应用程序中使用它。如何查询kafka（作为事件存储）某个聚合的事件以完成写入端的操作？

Answer 1

您可以使用 Kafka Streams ( http://docs.confluence.io/current/streams/index.html ) 来计算存储在 Kafka 中的数据聚合。在下一个版本中（投票已经正在进行），Kafka Streams 添加了一项名为“交互式查询”的新功能，允许您随时查询每个聚合的当前值。

现在请参阅设计文档（仍使用旧名称“Queryable State”）https://cwiki.apache.org/confluence/display/KAFKA/KIP-67%3A+Queryable+state+for+Kafka+Streams

发布后将有关于交互式查询如何工作的详细文档。如果您现在有后续问题，请继续。