越来越多的文章将kafka作为事件存储，并将其用于使用cqrs和事件源构建的应用程序中。如何查询kafka（作为事件存储）中某个聚合的事件以完成写端的操作？
bgibtngc1#
你可以使用Kafka流(http://docs.confluent.io/current/streams/index.html)计算存储在Kafka中的数据的集合。在下一个版本（投票已经在进行）中，kafka streams添加了一个名为interactive querys的新功能，允许您随时查询每个聚合的当前值。现在请参阅设计文档（仍然具有旧名称“queryable state”的特性）https://cwiki.apache.org/confluence/display/kafka/kip-67%3a+queryable+state+for+kafka+streams发布之后，将会有关于交互查询如何工作的详细文档。如果你现在有后续的问题，那就继续吧。
1条答案
按热度按时间bgibtngc1#
你可以使用Kafka流(http://docs.confluent.io/current/streams/index.html)计算存储在Kafka中的数据的集合。在下一个版本（投票已经在进行）中，kafka streams添加了一个名为interactive querys的新功能，允许您随时查询每个聚合的当前值。
现在请参阅设计文档（仍然具有旧名称“queryable state”的特性）https://cwiki.apache.org/confluence/display/kafka/kip-67%3a+queryable+state+for+kafka+streams
发布之后，将会有关于交互查询如何工作的详细文档。如果你现在有后续的问题，那就继续吧。