我正在为我的需要构建一个 apache 集群，其中大部分是无状态的。但是有一种情况我真的需要状态。
为了解释，假设我正在存储每家开业的药店以及在该店和每家商店发生的交易。所以商店以药物数量的初始状态打开。随着药品的销售和更多的药品库存，状态不断变化。
虽然 Kafka 满足了我实时跟踪实时交易的需求，但我需要能够建立药店状态和查询，并在任何给定点找出商店中给定药物的数量。是否可以？这就是 Kafka Stream 的用途吗？
问问题
2162 次
1 回答
4
是的，您可以使用 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
于 2017-01-08T05:39:27.900 回答