【Flink】Flink 1.13 版本 KafkaSource 代码解读

news2024/11/18 8:33:52

文章目录

  • 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

在这里插入图片描述

1.概述

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

扩展阅读࿱

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/96198.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Gradle学习笔记之任务

Gradle学习笔记之任务

文章目录任务入门任务行为任务的依赖方式参数依赖内部依赖外部依赖多种依赖方式的混合跨项目依赖任务执行gradle run命令演示gradle projects演示gradle tasks演示gradle tasks --all演示查看指定的任务组任务查看某一任务的详细信息查看项目的依赖关系查看项目的属性信息任务类…
阅读更多...
RCNN网络源码解读（Ⅱ） --- 使用IOU计算正负样本用于finetune训练

RCNN网络源码解读（Ⅱ） --- 使用IOU计算正负样本用于finetune训练

目录 1.预训练二分类器Alexnet 1.1 code（finetune.py） 2.二分类数据集处理 2.1 code（cerate_classifier_data.py） 1.预训练二分类器Alexnet 1.1 code（finetune.py） 1.引入头文件 import os import c…
阅读更多...
阿里是如何使用分布式架构的，阿里内部学习手册分享

阿里是如何使用分布式架构的，阿里内部学习手册分享

为什么要使用分布式架构？分布式架构解决了互联网应用的两大难题：高并发和高可用。高并发指服务器并发处理客户端请求的数量大，而高可用指后端服务能始终处于可用状态。 提高系统容量 随着业务越来越复杂，服务也会变得越来越复杂…
阅读更多...
CS61A Proj 2

CS61A Proj 2

更好的阅读体验 Project 2: CS 61A Autocorrected Typing Software cats.zip Programmers dream of Abstraction, recursion, and Typing really fast. Introduction Important submission note: For full credit: Submit with Phase 1 complete by Thursday, February 17, wo…
阅读更多...
ADI Blackfin DSP处理器-BF533的开发详解55：CVBS输入-DSP和ADV7180的应用详解（含源码）

ADI Blackfin DSP处理器-BF533的开发详解55：CVBS输入-DSP和ADV7180的应用详解（含源码）

硬件准备 ADSP-EDU-BF533：BF533开发板 AD-HP530ICE：ADI DSP仿真器 软件准备 Visual DSP软件 硬件链接 CVBS IN 视频输入 硬件实现原理 CVBS_IN 子卡板连接在 ADSP-EDU-BF53x 开发板的扩展端口 PORT3 和 PORT4 上，板卡插入时，…
阅读更多...
[内网渗透]—域外向域内信息收集、密码喷洒

[内网渗透]—域外向域内信息收集、密码喷洒

前言 当我们与目标内网建立了socks5隧道后，就可以从域外对域内机器进行信息搜集了，很多工具不用上传到目标机器，也就不易被AV检测到，但是有可能会被一些流量检测设备发现有大量socks5流量。 接下来介绍下如何通过域外对域内进⾏更深的信息搜集：枚举域⽤户、查看域内⽤户…
阅读更多...
【大数据技术Hadoop+Spark】HBase数据模型、Shell操作、Java API示例程序讲解（附源码 超详细）

【大数据技术Hadoop+Spark】HBase数据模型、Shell操作、Java API示例程序讲解（附源码 超详细）

一、HBase数据模型 HBase分布式数据库的数据存储在行列式的表格中，它是一个多维度的映射模型，其数据模型如下所示。表的索引是行键，列族，列限定符和时间戳，表在水平方向由一个或者多个列族组成，一个列族中…
阅读更多...
[附源码]Python计算机毕业设计红色景点自驾游网站管理系统Django（程序+LW）

[附源码]Python计算机毕业设计红色景点自驾游网站管理系统Django（程序+LW）

该项目含有源码、文档、程序、数据库、配套开发软件、软件安装教程 项目运行 环境配置： Pychram社区版 python3.7.7 Mysql5.7 HBuilderXlist pipNavicat11Djangonodejs。 项目技术： django python Vue 等等组成，B/S模式 pychram管理等…
阅读更多...
[附源码]Node.js计算机毕业设计古诗词知识学习系统Express

[附源码]Node.js计算机毕业设计古诗词知识学习系统Express

项目运行 环境配置： Node.js最新版 Vscode Mysql5.7 HBuilderXNavicat11Vue。 项目技术： Express框架 Node.js Vue 等等组成，B/S模式 Vscode管理前后端分离等等。 环境需要 1.运行环境：最好是Nodejs最新版，我…
阅读更多...
计算机毕设Python+Vue心理咨询预约系统（程序+LW+部署）

计算机毕设Python+Vue心理咨询预约系统（程序+LW+部署）

项目运行 环境配置： Jdk1.8 Tomcat7.0 Mysql HBuilderX（Webstorm也行） Eclispe（IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持）。 项目技术： SSM mybatis Maven Vue 等等组成，B/S模式 M…
阅读更多...
医院、诊所看这里，一个分诊屏+叫号系统，实现门诊高效排队叫号

医院、诊所看这里，一个分诊屏+叫号系统，实现门诊高效排队叫号

为维系患者候诊秩序，减少插队混乱的情况，医院、诊所等医疗机构会考虑采购智能排队叫号系统。 依照系统预定规则，对门诊患者进行数据排列，医生快捷呼叫，打造现代化有序的绿色门诊。 排队叫号系统，是将软件…
阅读更多...
「C#」异步编程玩法笔记-WinForm中的常见问题

「C#」异步编程玩法笔记-WinForm中的常见问题

目录 1、异步更新界面 1.1、问题 1.2、解决问题 1.3、AsyncOperationManager和AsyncOperation 1.4、Invoke、BeginInvoke、EndInvoke及InvokeRequired Invoke InvokeRequired BeginInvoke EndInvoke 2、死锁 2.1、问题 2.2、 解决方法 2.2.1、不要await 2.2.2、用…
阅读更多...
Jmeter(十八)：硬件性能监控指标

Jmeter(十八)：硬件性能监控指标

硬件性能监控指标 一、性能监控初步介绍 性能测试的主要目标 1.在当前的服务器配置情况，最大的用户数 2.平均响应时间ART，找出时间较长的业务 3.每秒事务数TPS，服务器的处理能力 性能测试涉及的内容 1.客户端性能测试：web前…
阅读更多...
【Redis】主从复制和哨兵模式

【Redis】主从复制和哨兵模式

主从复制 主从复制：主机数据更新后根据配置和策略， 自动同步到备机的master/slaver机制，Master以写为主，Slave以读为主 作用： 读写分离，性能扩展容灾快速恢复 主从复制的配置 在我的/myredis目录中&…
阅读更多...
第17章 前端之全局存储：Vuex=Store

第17章 前端之全局存储：Vuex=Store

17章 前端之全局存储：VuexStore Store用于对数据进行存储，并共享以为所有需要的Vue页面中的调用提供数据及其方法支撑；Vuex是Store的内置引用包，即如果想要前端Vue程序支撑Store必须在新建Vue程序；如果Vue程序没有引用…
阅读更多...
【python】一文带你理解并解决conda activate虚拟环境后，pip安装的包没放在虚拟环境

【python】一文带你理解并解决conda activate虚拟环境后，pip安装的包没放在虚拟环境

太长不看版 环境变量有问题，查看环境变量，应该会发现，在你虚拟环境的地址之前，有其他的地址，比如/home/xxx/.local/bin:等，而且这个地址里面刚好有pip,python这些程序。 最简单的办法：去把/hom…
阅读更多...
第十五章 Golang单元测试

第十五章 Golang单元测试

1. 先看一个需求 在我们工作中&#xff0c;我们会遇到这样的情况&#xff0c;就是去确认一个函数&#xff0c;或者一个模块的结果是否正确。 func addUpper(n int) int{res : 0for i : 1;i<n;i{res i}return res }2.传统方法的优缺点 不方便&#xff0c;我们需要在main函…
阅读更多...
java基于微信小程序的二手交易系统-计算机毕业设计

java基于微信小程序的二手交易系统-计算机毕业设计

项目介绍 开发语言&#xff1a;Java 框架&#xff1a;ssm JDK版本&#xff1a;JDK1.8 服务器&#xff1a;tomcat7 数据库&#xff1a;mysql 5.7&#xff08;一定要5.7版本&#xff09; 数据库工具&#xff1a;Navicat11 开发软件&#xff1a;eclipse/myeclipse/idea Maven包&a…
阅读更多...
QCC51XX---RAM资源查看

QCC51XX---RAM资源查看

QCC51XX---系统学习目录_嵌入式学习_force的博客-CSDN博客 想必大家有时会遇到一些memory的panic，就像下图的提示 这主要是内存溢出引起的。而内存溢出主要有内存池（memory pool）和RAM溢出两种，不管哪种溢出都是不规范使用内存或过度使用造成的。那具体有多少能用或怎么正确…
阅读更多...
SpringCloud 学习笔记

SpringCloud 学习笔记

❤ 作者主页&#xff1a;Java技术一点通的博客 ❀ 个人介绍&#xff1a;大家好&#xff0c;我是Java技术一点通&#xff01;(&#xffe3;▽&#xffe3;)~* &#x1f34a; 记得关注、点赞、收藏、评论⭐️⭐️⭐️ &#x1f4e3; 认真学习&#xff0c;共同进步&#xff01;&am…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023