业务情况: 源:kafka topic1 中间过滤表:sn表
输出:kafka topic2
'connector' = 'upsert-kafka',
insert into topic2
select * from topic1
where topic1中的SN 不在sn表中。
验证:
数据能过滤。 但是过滤数据插入后, 又把所有数据存储到 topic2中了?
但是不使用回撤流,又不能使用not in 。有什么破解方案?
相似问题