KSQLテーブルからデータを読み取る

Question

おそらくこれは初心者の質問ですが、KSQLで生成されたデータを読み取るにはどうすればよいですか？

ストリーム処理を行い、そのデータをKSQLテーブルに書き込むとします。今、Springアプリケーションを介してこのデータにアクセスしたいと考えています（websocket経由でライブデータをファンアウトするなど）。私の最初の推測は、スプリングカフカを使用して、根底にあるトピックに登録することでした。それともカフカストリームを使うべきですか？

もう1つの使用例は、ストリーム処理を行い、結果をRedisストア（たとえば、現在の値を常に返すWebサービス）に書き込むことです。ここでのアプローチは何ですか？

ありがとうございます！

Answer 1

KSQLクエリがKafkaトピックに格納されている場合の結果。結果トピックから読んで、サードパーティのアプリケーションから結果にアクセスすることができます。 クエリの結果がTableの場合、結果のカフカトピックは、CassandraやRedisなどのサードパーティシステムのテーブルに読み込むことができる、変更ログのトピックです。このテーブルには常に最新の結果があり、Webサービスからクエリを実行できます。 Clickstreamのデモで、結果をElasticにプッシュして視覚化してください。視覚化された値は、対応するテーブルの最新の値です。

https://github.com/confluentinc/ksql/tree/master/ksql-clickstream-demo#clickstream-analysis