Flink源码解析[Source](一) - 为什么要解析Source源码
概述
本系列文章是旨在熟悉摸头flink的source-connect原理，希望可以做到自己可以实现一个新的source，代码解析将会以kafka的实现配合flink的api为主线解析。
flink版本为1.12.0
第一篇：为什么要解析Source源码
第二篇：如何创建Flink kafka source
第三篇：新版Data Srouces详解&源码
问题
为了可以明白flink是如何Source抽象的
checkout依赖于Source可以回溯消费，代码上是怎么实现的？
source中watermark是如何实现的，代码结构是如何？
目标
- 理解flink-source的机制
- 理解kafka-flink的实现
- 理解pusar-flink的实现
可以熟透这块源代码，熟悉kafka以及pulsar的实现，并可以贡献源代码。