回复: Flink SQL 中同时写入多个 sink 时，是否能够保证先后次序

Wed, 12 Oct 2022 00:36:26 -0700 

Hi Zhiwen:

     
可以试试将kafkasink设置为exactly-once，同时下游任务的kafkasource设置为读已提交，不过如果你的checkpoint间隔很长，下游要很久才能从kafka拿到数据。

从 Windows 版邮件发送

发件人: Zhiwen Sun
发送时间: 2022年10月12日 14:42
收件人: user-zh@flink.apache.org
主题: Flink SQL 中同时写入多个 sink 时，是否能够保证先后次序

hi all：

我们有个场景，需要 Flink SQL 同时写入消息和 database， 后续实时任务消费消息，再次读取 database， 如果消息先于
database 写入，这就可能导致读取的数据不正确。

是否有办法保证 database 写入后，再发送消息？

Zhiwen Sun

回复