wangl...@geekplus.com.cn Tue, 10 Mar 2020 01:56:04 -0700
有两个 kafka 作为数据源的表 order_info: order_no info order_status: order_no status
两个表的 order_no 都会有重复,来一条其中一个表的记录,会在另外一个表中找到多条记录。 我怎样实现在另外一个表中只取出与该 join key 相关的最新的一条记录并发送到 kafka 中呢? kafka 只支持 append 模式的 sink,先把 表 group 再join 行不通。 谢谢, 王磊