Apache Kafkaでの状態の構築とクエリ：Kafka Stream？

Question

私のニーズに合ったApacheクラスタを構築しており、そのほとんどはステートレスです。しかし、私には本当に状態が必要な状況が1つあります。

説明するには、開店するすべての薬局店舗とその店舗で発生する取引をすべて保存しているとします。店は薬の数の初期状態で開きます。医薬品が販売され、より多くの医薬品が貯蔵されるにつれて、状態は絶えず変化し続ける。

リアルタイムでライブ取引に対応する必要がある一方で、薬局の店舗の状態とクエリを構築し、店舗内の特定の薬の数を特定のポイントで見つけることができる必要があります。出来ますか？それはカフカストリームが使われているのでしょうか？

Answer 1

はい、Kafkaストリームを使用して、カフカトピックを使用し、現在の薬物在庫を維持するために継続的に更新されるクエリ可能なストアを維持するアプリケーションを構築できます。

を始めるためにドキュメントをチェックアウト：http://docs.confluent.io/current/streams/index.html

をもカフカストリーム "インタラクティブ問合せ" 機能を使用してこれらの例をチェックアウト：

• 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