KSQL 查询和表存储
KSQL query and tables storage
我正在寻找有关 KSQL 存储查询和 table 位置的文档。例如，由于 KSQL 是为与 Kafka 一起工作而构建的，当我从主题创建 table 时，或者当我编写查询时，table 或查询结果存储在哪里？更具体地说，KSQL 是否使用某种指针指向主题分区内的段内的事件，或者当我从主题创建 table 时复制事件？
已 运行 或处于活动状态的查询将持久保存回 Kafka 主题。
Select 语句没有持久状态 - 它充当消费者
创建 Stream/Table 命令可能会创建许多主题，从而导致将输入主题复制、操纵和过滤到给定的目标主题。对于任何有状态操作，结果将存储在 KSQL 服务器上的 RocksDB 实例中。
由于KSQL是基于Kafka Streams构建的，你可以参考Kafka Streams Internal Data Management
上的wiki
我正在寻找有关 KSQL 存储查询和 table 位置的文档。例如，由于 KSQL 是为与 Kafka 一起工作而构建的，当我从主题创建 table 时，或者当我编写查询时，table 或查询结果存储在哪里？更具体地说，KSQL 是否使用某种指针指向主题分区内的段内的事件，或者当我从主题创建 table 时复制事件？
已 运行 或处于活动状态的查询将持久保存回 Kafka 主题。
Select 语句没有持久状态 - 它充当消费者
创建 Stream/Table 命令可能会创建许多主题，从而导致将输入主题复制、操纵和过滤到给定的目标主题。对于任何有状态操作，结果将存储在 KSQL 服务器上的 RocksDB 实例中。
由于KSQL是基于Kafka Streams构建的，你可以参考Kafka Streams Internal Data Management
上的wiki