我正在编写一个kafka流应用程序，它获取正在kafka主题中注册的传感器读数（作为中的消息） JSON )，并以每分钟、每小时和每天为单位对这些读数的值进行聚合。然后我实现了 KTables 从这些聚合派生，并使用默认状态存储来存储它们。我想知道是否可以使用 KSQL .
JSON
KTables
KSQL
mfpqipee1#
虽然kafka streams是ksql的运行时， KTables 通过kafka流应用程序打包的文件在ksql中不可用。如果你想有一个 TABLE 在ksql中，您需要编写一个ksql查询来创建 TABLE .但是请注意，ksql查询是连续查询，而不是关系数据库中的“查找”查询。相反，kafka流支持一种称为“交互式查询”的功能(https://docs.confluent.io/current/streams/developer-guide/interactive-queries.html)它允许您对 KTable .最后，在ksql中也有当前正在进行的工作，即公开“交互式查询”。
TABLE
KTable
1条答案
按热度按时间mfpqipee1#
虽然kafka streams是ksql的运行时，
KTables通过kafka流应用程序打包的文件在ksql中不可用。如果你想有一个TABLE在ksql中，您需要编写一个ksql查询来创建TABLE.但是请注意，ksql查询是连续查询，而不是关系数据库中的“查找”查询。
相反，kafka流支持一种称为“交互式查询”的功能(https://docs.confluent.io/current/streams/developer-guide/interactive-queries.html)它允许您对
KTable.最后，在ksql中也有当前正在进行的工作，即公开“交互式查询”。