在 Apache Kafka 中构建和查询状态：Kafka Stream？

Question

我正在为我的需要构建一个 apache 集群，其中大部分是无状态的。但是有一种情况我真的需要状态。

为了解释，假设我正在存储每家开业的药店以及在该店和每家商店发生的交易。所以商店以药物数量的初始状态打开。随着药品的销售和库存的增加，状态不断变化。

当 Kafka 满足我实时跟踪实时交易的需求时，我需要能够建立药店状态并查询并在任何给定点找出商店中给定药物的数量。可能吗？这就是 Kafka Stream 的用途吗？

Answer 1

是的，您可以使用 Kafka Streams 构建一个应用程序，该应用程序使用 Kafka 主题并维护一个不断更新的可查询存储，以维护当前的药品库存，如您的示例所示。

查看文档以开始使用：http://docs.confluent.io/current/streams/index.html

还可以使用 Kafka Streams 的“交互式查询”功能查看这些示例：

• https://github.com/confluentinc/examples/blob/3.1.x/kafka-streams/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesExample.java
• https://github.com/confluentinc/examples/blob/3.1.x/kafka-streams/src/main/java/io/confluent/examples/streams/interactivequeries/kafkamusic/KafkaMusicExample.java