apache-kafka - 使用 KSQL 查询 Kafka Streams KTable
问题描述
我正在编写这个 Kafka 流应用程序,它获取在 Kafka 主题中注册的传感器读数(作为 中的消息JSON
),并以每分钟、每小时和每天对这些读数的值执行一些聚合基础。然后我KTables
从这些聚合中实现派生并使用默认状态存储来存储它们。我想知道是否可以使用KSQL
.
解决方案
虽然 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 目前正在进行一项工作,以公开“交互式查询”。
推荐阅读
- javascript - Flipkart 如何访问 dom 元素以进行集成测试?
- tsql - MS-SQL:重建与重新创建的空间开销
- c# - 如何避免 EF Core 中的不安全上下文操作?
- bash - 从 netstat 端口检索路径的单线器
- istio - Istio 注入 DB 应用,将其服务类型设为 NodePort,该节点端口无法访问
- excel - VBA 刷新数据透视表
- amazon-web-services - 使用 terraform 创建 aws_flow_log 时出现访问错误
- spring-boot - Rest api 任务的黑客等级类添加
- java - 创建一个将在对象上设置值、返回对象或使用传递的参数设置的方法?
- android - 在通知通道中启用声音按钮