FlinkFlink 1.13 版本 KafkaSource 代码解读
Posted 九师兄
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了FlinkFlink 1.13 版本 KafkaSource 代码解读相关的知识，希望对你有一定的参考价值。
文章目录
1.概述
因为最近看到新版本的kafka source进行改版了，于是就想测试一下看看最新版本的如何使用，顺便debug一下，看看实现原理
扩展阅读
以上是关于FlinkFlink 1.13 版本 KafkaSource 代码解读的主要内容，如果未能解决你的问题，请参考以下文章
FlinkFlink 1.13 编译 报错 Too many files with unapproved license
FlinkFlink 1.13 编译 报错 Too many files with unapproved license
FlinkFlink 1.13 Flink SQL 新特性 性能优化 时区 时间 纠正
FlinkFLink 1.13 3 种 命令客户端 GenericCLI FlinkYarnSessionCliDefaultCLI