业务情况: 源:kafka topic1 中间过滤表:sn表
输出:kafka topic2
'connector' = 'upsert-kafka',
insert into topic2
select * from topic1
where topic1中的SN 不在sn表中。
验证:
数据能过滤。 但是过滤数据插入后, 又把所有数据存储到 topic2中了?
但是不使用回撤流,又不能使用not in 。有什么破解方案?
发布于 2022-06-15 09:27:28
您好,文字识别不支持将繁体字识别为简体字。
相似问题
领取专属 10元无门槛券
AI混元助手 在线答疑
洞察 腾讯核心技术
剖析业界实践案例