apache-kafka - 使用 KSQL 查询 Kafka Streams KTable

Question

我正在编写这个 Kafka 流应用程序，它获取在 Kafka 主题中注册的传感器读数（作为 中的消息JSON），并以每分钟、每小时和每天对这些读数的值执行一些聚合基础。然后我KTables从这些聚合中实现派生并使用默认状态存储来存储它们。我想知道是否可以使用KSQL.

Answer 1

虽然 Kafka Streams 是 KSQL 的运行时，KTables但您通过 Kafka Streams 应用程序创建的在 KSQL 中不可用。如果你想TABLE在 KSQL 中有一个，你需要编写一个 KSQL 查询来创建它TABLE。

但是请注意，KSQL 查询是连续查询，而不是关系数据库中的“查找”查询。

相比之下，Kafka Streams 支持一种称为“交互式查询”（https://docs.confluent.io/current/streams/developer-guide/interactive-queries.html）的功能，它允许您对状态进行基于键的查找一个KTable。

最后，KSQL 目前正在进行一项工作，以公开“交互式查询”。