是的。FLIP-105之后，我们也会考虑引入一些简化的 format 去描述 cdc 数据，比如 csv 的第一列用来描述 change operation。
Best, Jark On Sun, 26 Apr 2020 at 10:14, Benchao Li <libenc...@gmail.com> wrote: > Hi， > > 暂时还不能做到，有一个FLIP[1] 正在做这件事，应该在1.11之后会逐步具备这个能力。 > > [1] > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=147427289 > > lec ssmi <shicheng31...@gmail.com> 于2020年4月26日周日 上午10:08写道： > > > Hi: > > 假设我现在将上游retract后的结果写入到kafka，然后下游程序消费kafka去做聚合操作。 > > 因为需要利用聚合算子能够自动处理retract的特性，所以需要将kafka的结果封装成带有不同header的row，即组装为INSERT > > DELETE UPDATE类型的数据。 > > 有什么办法可以解决吗？ > > 如果将上下游程序合在一起 ，是没问题的，现在的难点就是拆分。 > > 谢谢。 > > > > > -- > > Benchao Li > School of Electronics Engineering and Computer Science, Peking University > Tel:+86-15650713730 > Email: libenc...@gmail.com; libenc...@pku.edu.cn >
