FlinkFlink 实现 AT_LEAST_ONCE & EXACTLY_ONCE 案例
Posted 九师兄
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了FlinkFlink 实现 AT_LEAST_ONCE & EXACTLY_ONCE 案例相关的知识，希望对你有一定的参考价值。
1.概述
本博客是 Apache Flink 知其然，知其所以然（原理&实战） 的笔记。
@Test
public void main1() throws Exception {
StreamExecutionEnvironment env 以上是关于FlinkFlink 实现 AT_LEAST_ONCE & EXACTLY_ONCE 案例的主要内容，如果未能解决你的问题，请参考以下文章
FlinkFlink 基于 MailBox 实现的 StreamTask 线程模型
FlinkFlink 消费 kafka 实现 限流处理 RateLimiter
FlinkFlink 实现 End to End 的 EXACTLY_ONCE
FlinkFlink 1.12.2 源码浅析 : TaskExecutor