これは初心者の質問かもしれませんが、KSQL で生成されたデータを読み取るための推奨される方法は何ですか?
ストリーム処理を行って、データを KSQL テーブルに書き込むとします。ここで、Spring アプリケーションを介してこのデータにアクセスしたいと考えています (たとえば、Websocket を介していくつかのライブ データをファンアウトします)。ここで最初に推測したのは、Spring Kafka を使用して、基礎となるトピックをサブスクライブすることでした。または、Kafka Streams を使用する必要がありますか?
もう 1 つの使用例は、ストリーム処理を実行し、結果を Redis ストアに書き込むことです (たとえば、常に現在の値を返す Web サービスの場合)。ここでのアプローチは何でしょうか？
ありがとう！
KSQL クエリが Kafka トピックに格納されている場合の結果。そのため、結果トピックから読み取ることで、サードパーティ アプリケーションからの結果にアクセスできます。クエリ結果がTable結果の Kafka トピックである場合は、Cassandra や Redis などのサード パーティ システムのテーブルにそれを読み取ることができることを意味する変更ログ トピックです。このテーブルには常に最新の結果が含まれており、Web サービスからクエリを実行できます。視覚化のために結果を Elastic にプッシュする Clickstream デモをご覧ください。視覚化された値は、対応するテーブルの最新の値です。
https://github.com/confluentinc/ksql/tree/master/ksql-clickstream-demo#clickstream-analysis