上传者: 38677234
|
上传时间: 2021-11-26 14:29:24
|
文件大小: 524KB
|
文件类型: -
Flink 整合 Kafka 基本步骤,请参考:Flink 基础整合 Kafka。本文仅用来介绍 Flink 整合 Kafka 实现 Exactly-Once。
1.什么是Exactly-Once
恰好处理一次的意思。不管在处理的时候是否有异常发生,计算的结果都一样。即使在发现机器或者软件故障时,都不会出现数据丢失以及重复处理的情况。(就是每条数据只会被处理一次)
Flink 中哪些 Source 、Sink支持 Exactly-Once 呢,Flink官方文档(链接)为我们做了描述。如下图所示:
Source:
Sink:
我们发现很多都是 a