イベントソースとしてkafkaをイベントソースとして補充

kafkaをイベントストアとして使用し、cqrs &イベントソーシングで構築されたアプリケーションで使用する記事がますます増えています。書面側で操作を完了するために、特定の集約のイベントに対してkafka（イベントストアとして）をどのように照会しますか？イベントソースとしてkafkaをイベントソースとして補充

出典

2016-10-15 hsen

カフカストリーム（http://docs.confluent.io/current/streams/index.html）を使用して、カフカに格納されたデータの集計を計算することができます。次回のリリース（投票は既に進行中）で、Kafka Streamsにはというインタラクティブクエリと呼ばれる新機能が追加され、いつでもそれぞれの集計の現在の値を照会することができます。

は、リリース後にどのようにインタラクティブクエリの仕事についての詳細なドキュメントが存在しますhttps://cwiki.apache.org/confluence/display/KAFKA/KIP-67%3A+Queryable+state+for+Kafka+Streams

（まだ機能旧名称「照会可能状態」で）今の設計ドキュメントを参照してください。あなたが今質問をフォローアップしているならば、ただ進みましょう。

出典

2016-10-17 07:27:22

kafkaとqueryable状態の使用方法に関する例はありますか？すべてのイベントを同じトピックにする必要がありますか？ 1つの集約は複数のタイプのイベントを持つことができ、私は各イベントに独自のトピックがあることを前提としています。 – hsen

kafkaとクエリー可能な状態を使用する方法の例はありますか？すべてのイベントを同じトピックにする必要がありますか？ 1つの集約は複数のタイプのイベントを持つことができ、私は各イベントに独自のトピックがあることを前提としています。特定の集約の状態を照会するには、これらのすべてのイベントの結果を順に集計する必要があります。カフカを間違った方法で使っていますか？ – hsen

ここに2つの例があります：https://github.com/confluentinc/examples/blob/master/kafka-streams/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesExample.javaとhttps：// github.com/confluentinc/examples/blob/master/kafka-streams/src/main/java/io/confluent/examples/streams/interactivequeries/kafkamusic/KafkaMusicExample.java （このレポには他のカフカストリームの例もあります）。 –

イベントソースとしてkafkaをイベントソースとして補充

答えて

関連する問題