首页 > 解决方案 > 当我们运行 kSQL 查询时,内部会发生什么?

问题描述

我对 Apache Kafka 和 kSQL 完全陌生。我脑子里有一个问题,我试图找出答案,但我没有这样做。

我目前的理解是,生产者生成的事件以序列化形式(0 和 1)的主题存储在 Kafka 内部。如果我创建一个 Kafka 流来使用数据,然后,如果我运行 kSQL 查询,假设使用 COUNT() 函数,那么该查询的输出将保留在 Kafka 主题中。

如果是这种情况,它不会是存储成本吗?

标签: apache-kafkaksqldb

解决方案


在幕后,它运行一个 Kafka Streams 拓扑。

在您的情况下,任何持久流或聚合表确实会占用存储空间。


推荐阅读