apache-kafka - KSQL 查询和表存储
问题描述
我正在寻找有关 KSQL 存储查询和表的位置的文档。例如,由于 KSQL 是为与 Kafka 一起工作而构建的,所以当我从主题创建表时,或者当我编写查询时,表或查询结果存储在哪里?更具体地说,例如,KSQL 是否使用某种指向主题分区内段内事件的指针,或者它在我从主题创建表时复制事件?
解决方案
已运行或处于活动状态的查询将持久化回 Kafka 主题。
Select 语句没有持久状态 - 它充当消费者
Create Stream/Table 命令可能会创建许多主题,从而导致将输入主题复制、处理和过滤到给定的目标主题。对于任何有状态的操作,结果将存储在 KSQL 服务器上的 RocksDB 实例中。
由于 KSQL 是基于 Kafka Streams 构建的,您可以参考Kafka Streams Internal Data Management上的 wiki
推荐阅读
- image-processing - 使用 imagemagick 处理图像并嵌入网络时,我应该留下还是去除嵌入的颜色配置文件?
- reactjs - TypeError: (0, _react.default) 不是函数
- javascript - 我的 if 语句没有显示/隐藏元素,我不知道为什么
- c# - 客户端无法连接到 mqtt 代理并出现错误:远程证书被提供的拒绝
- c# - 在继承的 ViewComponent .net core 5.0 中覆盖 Invoke 方法
- blockchain - Solana - 如何获得外国账户的代币余额?
- typescript - 声明为联合类型的常量在导出时降级为字符串
- css - 属性“WebkitBoxOrient”的类型不兼容
- sqlite - GORM:引用同一张表
- latex - 表格图中生成的缺少 $ 插入错误