KSQLDB 从多个流中创建一个流而无需连接

Question

是否可以在没有 join / window 子句的情况下将多个流连接到一个流？我只是想要一些类似于组合的 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，但该解决方案需要在创建新流后手动插入语句。有没有办法在一条语句中完成？

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

编辑:// 告知所有小伙伴。如果您使用插入到 select... 将创建一个运行查询并且最终流将接收进一步更新

Answer 1

通知各位小伙伴。如果您使用 insert into select...-语句，将创建一个运行查询，最终流将接收进一步的更新。

KSQLDB 从多个流中创建一个流而无需连接

KSQLDB create a stream from multiple streams without join

ksqldb