hi star, Flink 1.11 开始已经支持 table source 读取 retract 消息,update 消息。 目前支持 Debezium format,Canal format [1],其他的情况目前需要自己实现。
Best, Godfrey [1] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=147427289#FLIP105:SupporttoInterpretChangeloginFlinkSQL(IntroducingDebeziumandCanalFormat)-CanalFormat 1048262223 <1048262...@qq.com> 于2020年6月3日周三 下午2:59写道: > Hi > Flink 中RetractStream > 是必须要sink支持update的,kafka消息队列本身是不支持update的,所以基于sink为kafka的程序是不能做RetractStream的。 > > > Best, > Yichao Yang > > > ------------------ 原始邮件 ------------------ > 发件人: "star"<3149768...@qq.com>; > 发送时间: 2020年6月3日(星期三) 下午2:47 > 收件人: "user-zh@flink.apache.org"<user-zh@flink.apache.org>; > > 主题: flink 1.9 关于回撤流的问题 > > > > 大家好, > > > > 在做实时统计分析的时候我将基础汇总层做成了一个回撤流(toRetractStream)输出到kafka里(因为后面很多实时报表依赖这个流,所以就输出了) > 问题是这个kafka里到回撤流还能转成flink 的RetractStream流吗,转成后我想注册成一张表,然后基于这个表再做聚合分析 > > > > > 谢谢