开发者社区 问答 正文

用FlinkKafkaProducer011写kafka的exactly once的困惑

各位大神好,有个困惑。用FlinkKafkaProducer011写kafka的exactly once,比如我的checkpoint是十分钟,是否在十分钟之内,都不会往kafka下游发送数据。因为我看flink源码,是有在执行snapshotState的时候才kakfa的producer才flush了。*来自志愿者整理的flink邮件归档

展开
收起
船长的小螺号 2021-12-03 10:20:30 1073 分享 版权
1 条回答
写回答
取消 提交回答
  • 应该是所有operator完成各自的pre-commit,它们会发起一个commit操作,然后才会flush*来自志愿者整理的FLINK邮件归档

    2021-12-03 10:48:18
    赞同 展开评论