首页 > 解决方案 > KSQL 查询和表存储

问题描述

我正在寻找有关 KSQL 存储查询和表的位置的文档。例如,由于 KSQL 是为与 Kafka 一起工作而构建的,所以当我从主题创建表时,或者当我编写查询时,表或查询结果存储在哪里?更具体地说,例如,KSQL 是否使用某种指向主题分区内段内事件的指针,或者它在我从主题创建表时复制事件?

标签: apache-kafkaksqldb

解决方案


已运行或处于活动状态的查询将持久化回 Kafka 主题。

Select 语句没有持久状态 - 它充当消费者

Create Stream/Table 命令可能会创建许多主题,从而导致将输入主题复制、处理和过滤到给定的目标主题。对于任何有状态的操作,结果将存储在 KSQL 服务器上的 RocksDB 实例中。

由于 KSQL 是基于 Kafka Streams 构建的,您可以参考Kafka Streams Internal Data Management上的 wiki


推荐阅读