通过flink保存点读取重复的消息-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

通过flink保存点读取重复的消息

flink小助手 2018-12-10 10:36:55 875

我正在尝试使用Apache Flink 1.6.0从kafka主题中读取一些消息,转换它们并最终将它们发送到另一个kafka主题。在取消和重新声明的情况下,我使用保存点来保存应用程序的状态。问题是我重启后重复阅读邮件。kafka版本是011.

消息中间件 Kafka Apache 流计算
分享到
取消 提交回答
全部回答(1)
  • flink小助手
    2019-07-17 23:19:04

    为避免重复,Semantic.EXACTLY_ONCE在设置kafka生产者时必须通过。

    0 0
微服务
使用钉钉扫一扫加入圈子
+ 订阅

构建可靠、高效、易扩展的技术基石

推荐文章
相似问题
推荐课程