Flink笔记(二十三):Flink 整合 Kafka (实现 Exactly Once)

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