Flink RetractStream如何转成AppendStream?

Sat, 07 Dec 2019 18:08:37 -0800 

在用Flink做实时数仓时遇到group by统计后需要将结果发到kafka，但是现在的kafka
sink是不支持RetractStream，因此会报错，有没有什么方法将RetractStream转成AppendStream（例如，忽略撤回的消息，只发送更新的消息），从而可以将结果发到kafka?

回复