我有两个不同的 kafka 主题，其中有相同的字段ID。当流在这两个主题上接收到相同的 id 时，是否可以监听这两个主题并向第三个主题写入新消息？
问问题
407 次
1 回答
1
也许您可以执行窗口连接。也许这会有所帮助： https ://kafka.apache.org/10/documentation/streams/developer-guide/dsl-api#kstream-kstream-join
对于流-流连接，重要的是要强调一侧的新输入记录将为另一侧的每个匹配记录生成连接输出，并且在给定的连接窗口中可以有多个这样的匹配记录
于 2020-07-30T09:55:53.243 回答