KSQL窗口表无法创建持久查询：如何导出结果到新Topic

KSQL不支持对窗口表执行持久化导出查询，你可以直接在聚合阶段就将结果输出到目标Topic，无需先创建中间窗口表：

• 保留你已创建的源Stream：

CREATE STREAM amazon_changes (user VARCHAR KEY, title VARCHAR) 
WITH (KAFKA_TOPIC = 'amazon', VALUE_FORMAT = 'JSON', PARTITIONS = 1);

• 直接创建带1分钟滚动窗口的聚合表，并指定输出到amazon_changes_output Topic：

CREATE TABLE amazon_user_changes
WITH (KAFKA_TOPIC = 'amazon_changes_output', VALUE_FORMAT = 'JSON')
AS SELECT
    user,
    COUNT(*) AS count
FROM amazon_changes
WINDOW TUMBLING (SIZE 1 MINUTES)
GROUP BY user
EMIT CHANGES;

这样聚合后的窗口统计结果会直接写入到amazon_changes_output Topic，完全替代你之前“创建窗口表再导出”的流程。

如果已经存在之前的窗口表，你只能通过临时查询（比如SELECT * FROM amazon_user_changes EMIT CHANGES;）查看结果，但临时查询不会将数据持久化到Topic。要实现持久化输出，上面的直接指定Topic的方式是唯一可行的方案。

内容的提问来源于stack exchange，提问作者Alex238