ksql

0熱

1答えて

KSQL - ドロップトピック

KSQLからトピックを削除する方法はありますか？ githubによれば、試してみることができます。 DROP TOPIC my-topic DROP TOPIC "my-topic" DROP TOPIC 'my-topic' DROP TOPIC `my-topic` しかし、どちらのコマンドも機能しません。私はメッセージを受け取る Message -----------------

apache-kafka ksql 2017-12-05

---

1熱

1答えて

カフカから最新の値を取得

私はAというカフカのトピックを持っています。トピック内のデータの 形式は次のとおりです。今 { id : 1, name:stackoverflow, created_at:2017-09-28 22:30:00.000} { id : 2, name:confluent, created_at:2017-09-28 22:00:00.000} { id : 3, name:kafka, cr

apache-kafka apache-kafka-streams confluent-kafka ksql 2017-12-15

---

2熱

1答えて

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

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

apache-kafka apache-kafka-streams apache-kafka-connect spring-kafka ksql 2017-12-27

---

2熱

1答えて

KSQLですべてのエントリを数える

KSQLを使用して、特定のカラムのエントリをGROUP BYでカウントするのではなく、アプリケーションをストリームするすべてのエントリに対して集計を取得できますか？ 私はこのような何かを探しています：KSQLで | Count all | Count id1 | count id2 | | ---245----|----150----|----95-----| 以上のこのような： [some

apache-kafka apache-kafka-streams ksql 2017-11-14

---