在ksqldb headless部署模式下使用CREATE STREAM查询更改源主题名称



我有一个主题,它的名字包含点,它是用Debezium连接器创建的,它在那里,我不能做太多关于它。

使用ksqldb,我必须从中创建一个物化的流视图,但是在SELECT子句中不允许使用带点的主题名。

所以我必须首先用一个新名称声明原始主题,对吗?

CREATE STREAM datachanges_my_event WITH (KAFKA_TOPIC='datachanges.my.event', <...>);

,然后创建物化流视图

CREATE STREAM my_filtered_event AS SELECT <expr> FROM datachanges_my_event WHERE <condition> EMIT CHANGES;

这一切都很好,但是现在我必须尽我最大的努力把它作为headless模式部署的一部分;但是,第一个KSQL查询不是持久化的,在headless模式下没有意义。另一方面,我不能在交互模式下运行第一个查询,而在无头部署模式下运行第二个查询。

那么,请问,如何在作为ksqldb headless部署的一部分运行的查询中更改源主题的名称?

谢谢。

如果没有CREATE STREAM AS查询来创建物化流视图,则不能在无头模式下运行CREATE STREAM查询。

最新更新