FlinkFlink1.13版本KafkaSource代码解读

篇首语：本文由编程笔记#小编为大家整理，主要介绍了FlinkFlink 1.13 版本 KafkaSource 代码解读相关的知识，希望对你有一定的参考价值。

文章目录

• 1.概述


• 2. 案例


• 3.源码解读


• 
  
  
  
  • 3.1 build
  
  
  • 3.2 handleOperatorEvent
  
  
  • 3.3 addSplits
  
  
  • 3.4 createSplitFetcher
  
  
  • 3.5 创建SplitFetcher
  
  
  • 2.6 运行
  
  
  • 2.7 启动 SplitFetcher
  
  
  • 2.8 runOnce
  
  
  • 2.9 fetchTask.run
  
  
  • 2.9 fetch
  
  

因为最近看到新版本的kafka source进行改版了，于是就想测试一下看看最新版本的如何使用，顺便debug一下，看看实现原理

扩展阅读࿱