Flink kafka source & sink 源码解析 Flink kafka source & sink 源码解析 本文基于 Flink 1.9.0 和 Kafka 2.3 版本，对 Flink Kafka source 和 sink 端的源码进行解析。
Flink 1.9 实战：使用 SQL 读取 Kafka 并写入 MySQL Flink 1.9 实战：使用 SQL 读取 Kafka 并写入 MySQL 本文衍生于伍翀（云邪）在2019年8月31日 「Apache Kafka × Apache Flink Meetup 深圳站」上的分享《Flink SQL 1.9.0 技术内幕和最佳实践》。会后许多小伙伴对最后演示环节的 Demo 代码非常感兴趣，迫不及待地想尝试下，所以写了这篇文章分享下这份代码。希望对于 Flink SQL 的初学者能有所帮助。
Apache Flink 结合 Kafka 构建端到端的 Exactly-Once 处理 Apache Flink 结合 Kafka 构建端到端的 Exactly-Once 处理 描述Flink checkpoint机制是如何保证Flink程序结果的Exactly-Once的 显示Flink如何通过两阶段提交协议与数据源和数据输出端交互，以提供端到端的Exactly-Once保证 通过一个简单的示例，了解如何使用TwoPhaseCommitSinkFunction实现Exactly-Once的文件输出
浙公网安备 33010802010061号