kafka流是否可以监听两个主题,然后等待与id匹配的另一个事件,并在收到后将其发布到另一个主题



我有两个不同的kafka主题,其中有相同的字段Id。当流在这两个主题上接收到相同的Id时,它可以监听这两个话题并向第三个主题写入新消息吗?

也许您可以执行窗口连接。也许这会有所帮助:https://kafka.apache.org/10/documentation/streams/developer-guide/dsl-api#kstream-kstream加入

对于流流连接,重要的是要强调,一侧的新输入记录将为另一侧的每个匹配记录生成连接输出,并且在给定的连接窗口中可能有多个这样的匹配记录

相关内容

最新更新