KSQLDB从多个流创建一个流而不连接

Question

是否可以在没有连接/窗口子句的情况下将多个流连接到一个流？我只想要与组合 kafka 主题类似的东西，可以在其中找到所有消息以进行进一步处理。

                     /--->transformationOnValueX stream ---\
kafka topic source1:/---->transformationOnValueY stream ----\
                     /--->TransformationOnValueW stream -----\
kafka topic source2:/---->TransformationOnValueZ stream ------\------> combind_stream_all_messages_transformed_multiple_sources

知道怎么做吗？

编辑：// 找到https://kafka-tutorials.confluent.io/merge-many-streams-into-one-stream/ksql.html，但该解决方案需要在创建新流后手动插入语句。有没有办法在一个语句中做到这一点？

作为副作用，事件驱动的性质被打破了，还是我错了？如果在 insert into 语句之后将事件发布到源主题会发生什么？是不是丢了？

编辑：// 通知所有同胞。如果您使用 insert into select... 将创建一个正在运行的查询，并且最终流将收到进一步的更新

Answer 1

通知所有伙伴。如果您使用 insert into select...-statement，将创建一个正在运行的查询，并且最终流将接收进一步的更新。