如果你已经会用 SQL 查数、写得了简单的 Python 脚本,但一碰到"数据实时进来、要边算边存、还要能随时回查历史"就不知道从哪下手,这门 Flink 课值得先看一眼。反过来,如果你连 Kafka 是什么、批处理和流处理差在哪都还没概念,直接上这门课会比较吃力,建议先把消息队列和基础 SQL 补上。 它解决的是哪类工作场景 课程的主线不是把 Flink…
如果你已经会用 SQL 查数、写得了简单的 Python 脚本,但一碰到"数据实时进来、要边算边存、还要能随时回查历史"就不知道从哪下手,这门 Flink 课值得先看一眼。反过来,如果你连 Kafka 是什么、批处理和流处理差在哪都还没概念,直接上这门课会比较吃力,建议先把消息队列和基础 SQL 补上。
课程的主线不是把 Flink 的 API 从头到尾念一遍,而是围绕一个具体的落地场景展开:用 Flink 做实时数据处理,再用数据湖的存储方式把流式和批式打通,也就是标题里说的"湖仓一体"。对应到日常工作上,大概是这几类任务:业务库的变更要实时同步到分析侧、埋点日志需要边清洗边入湖、报表既要求分钟级延迟又要求能查几个月前的明细。这些场景的共同点是——只靠离线跑批跟不上,只靠传统数仓又存不下、查不动。
课程里对 Kafka 的安排也说明了这一点。它没有把消息队列当成一个孤立的知识点讲,而是放在"数据从哪来、怎么接进来"的位置上,属于架构链路里的必要一环,而不是为了凑章节。
按课程的推进方式,跟完一遍并动手做过练习的话,比较现实的目标是:能自己搭起一条从数据源接入、到 Flink 做转换聚合、再落到湖仓存储的最小链路;能读懂一段别人写的 Flink 作业在干什么,并在它出问题时定位到是接入、计算还是写出环节;能根据数据量和延迟要求,对并行度、检查点这类参数做基本调整。这些都是可以在面试或实际项目里说清楚、动手演示的东西。
需要提前说明的是,湖仓一体本身是个偏架构的话题,一门课能让你跑通链路、理解各层职责,但真正在生产环境里做选型和调优,还是要靠在具体项目上磨。把它当成"能上手"而不是"能扛生产",心态会更稳。
整份资料按 31 章推进,大致是"概念铺垫—组件打通—实战项目"的顺序。前面几章用于建立对 Flink 运行机制的基本认识,中间部分围绕 Kafka 接入、状态管理、检查点这些关键机制展开,后面落到一个综合性的实战项目,把前面散着的点串起来。这种结构的好处是不容易半途掉队,缺点是前面概念章节节奏偏慢,急性子的人容易想跳——但不建议跳,状态和检查点这两块跳过之后,后面的实战基本看不懂。
建议不要按顺序"看"完,而是按动手的节奏走。概念章节可以快速过一遍,知道每个组件负责什么就行;到了接入和实战部分,一定要在本地把环境跑起来,哪怕数据量很小。Flink 这门技术纸上看和实际跑差别很大,很多坑只有提交作业、看到报错才会暴露。实战项目部分建议先自己试着搭一遍,卡住了再回看对应章节,比跟着敲一遍印象深得多。
最后一句实在话:这门课的价值在于帮你把碎片化的实时计算知识串成一条能落地的链路,而不是给你一个可以直接抄进生产的方案。抱着这个预期去学,收获会比较实在。
Flinkʵսһܹ
dzFlinkKafka𡢼ؼʵսĿʺϴżס
Flinkŵʵսȫһܹմݴļܡ
? {9}--9¹±Kafka
{9}--9¹±Kafkaĵ.png [493.5 KB]
[9.9]--9-9Kafka夭使.mp4 [50.8 MB]
[9.4]--9-4kafka-topics泻牟.mp4 [55.2 MB]
[9.2]--9-2堑小纸械诘愕afka牟希.mp4 [14.4 MB]
[9.3]--9-3堑小纸械诘愕afka牟拢.mp4 [106.3 MB]
[9.8]--9-8诘Kafka疟(1).mp4 [20.9 MB]
[9.7]--9-7堑小纸械诘Kafka牟.mp4 [108.8 MB]
(9.1)--9-10Թ.pdf [28.8 KB]
[9.8]--9-8诘Kafka疟.mp4 [20.9 MB]
? {1}--1´ѡнرҿFlinkɴ
{1}--1´ѡнرҿFlinkɴؿ.png [493.5 KB]
(1.1)--1-9小士Flink展史&氐&业.pdf [70.5 KB]
[1.1]--1-1薪莨师乇埽么.mp4 [36.9 MB]
(1.2)--1-10Թ.pdf [28.3 KB]
? {31}--31转Flink目实战之FlinkHudi
{31}--31转Flink目实战之FlinkHudi.png [493.5 KB]
? {10}--10KafkaߣϢ&API
{10}--10KafkaߣϢ&API.png [493.5 KB]
[10.11]--10-11Kafka远芸.mp4 [36.3 MB]
[10.15]--10-15--铡谈谈Kafka械.mp4 [23.6 MB]
[10.9]--10-9Kafka越源.mp4 [42.7 MB]
[10.14]--10-14--铡谈谈Kafka械acks.mp4 [108.3 MB]
[10.13]--10-13--铡谈谈Kafka械母约.mp4 [68.9 MB]
(10.1)--10-20Թ.pdf [31.3 KB]
10-18 准一实之芸.mp4 [28.6 MB]
[10.10]--10-10Kafka越源泄证.mp4 [69.0 MB]
[10.19]--10-19KafkaTopic诘Partition莸.mp4 [14.4 MB]
[10.8]--10-8Kafka姆为谴什么.mp4 [63.2 MB]
[19.21]--19-21展之实时平台.mp4 [29.8 MB]
(19.1)--19-30Թ.pdf [32.0 KB]
? {28}--28¾ClickHouseFlinḳFlin
{28}--28¾ClickHouseFlinḳFlin.zip [1.8 MB]
? {30}--30陆铱莺纱莺源品Hudi使icl
? {5}--5¸ЧݴʽFlinkTransformatio
(5.1)--5-11Թ.pdf [40.3 KB]
? {11}--11KafkaBrokerKafkaϢЧ洢
(11.1)--11-8Թ.pdf [28.6 KB]
[11.6]--11-6Kafka荽娲⑵鸽讲.mp4 [165.5 MB]
? {29}--29转Flink目实战之澹篎linkClickH
[29.2]--29-2实战芨.mp4 [28.3 MB]
? {25}--25ClickHouseDDL&DML&am
(26.1)--26-23Թ.pdf [30.7 KB]
? {22}--22ս忪ԴClickHouseҿCHɴ
? {20}--20ݲɼFlinkCDCFlinkCDCʵ
[20.2]--20-2实时莶杉.mp4 [27.8 MB]
(20.1)--20-13Թ.pdf [34.6 KB]
[20.9]--20-9CDC什么位每始取.mp4 [13.2 MB]
? {15}--15ʱʵʱӰ죺Flinkʱ弰WindowA
[15.6]--15-6WindowAssigners职鸺岸应Window.mp4 [44.2 MB]
(15.1)--15-20Թ.pdf [29.7 KB]
(16.1)--16-9Թ.pdf [27.6 KB]
[16.6]--16-6要酆媳之.mp4 [58.1 MB]
[16.7]--16-7要酆媳之.mp4 [41.6 MB]
? {2}--2一丝椋菏笷link斜
[2.2]--2-2Flink俜峁╊构Flink应贸.mp4 [90.7 MB]
[2.6]--2-6毓之远Function姆式.mp4 [25.2 MB]
[2.9]--2-9通Flink院模式业.mp4 [23.2 MB]
[2.3]--2-3IDEA+MavenFlink应贸谋乜.mp4 [72.3 MB]
[2.7]--2-7毓之Lambda式写.mp4 [70.8 MB]
(27.1)--27-10Թ.pdf [29.1 KB]
[27.7]--27-7ClickHouse元之貌同维缺元.mp4 [19.3 MB]
? {23}--23ClickHouse;ClickHous
? {24}--24ClickHouseúClickHous
? {18}--18转Flink目实战之实时统之荽
(18.1)--18-11Թ.pdf [25.8 KB]
[18.5]--18-5Flink越Kafka毓V2.mp4 [17.6 MB]
[18.2]--18-2FlinkKafka应贸诘.mp4 [75.4 MB]
[18.4]--18-4Flink越Kafka毓V1.mp4 [43.9 MB]
[18.3]--18-3取募械牟.mp4 [48.0 MB]
? {6}--6麓鲁獠肯低矲linkSinkAPI
[6.5]--6-5Sink实之远Sink募系统.mp4 [64.8 MB]
(6.1)--6-9Թ.pdf [24.5 KB]
? {21}--21转Flink目实战之模实时统之直
(21.1)--21-8Թ.pdf [34.0 KB]
[21.4]--21-4实之荽写.mp4 [86.5 MB]
? {13}--13¾KafkaCPʹãKafkaⲿϵͳ
[13.2]--13-2识Kafka&实时芄械位.mp4 [68.3 MB]
[13.5]--13-5FlumeKafkaSource越拥斩斯芸.mp4 [44.4 MB]
(3.1)--3-2áͨ.pdf [587.2 KB]
[3.8]--3-9使FlinkWebUI峤辉糉link应贸.mp4 [20.9 MB]
[3.6]--3-7洹口毙昏定FlinkWebUI.mp4 [48.1 MB]
[3.7]--3-8态莶Flink应贸.mp4 [22.8 MB]
[3.10]--3-11要使械姆式峤籉link应贸.mp4 [48.4 MB]
[3.11]--3-12探Flink群模式.mp4 [79.9 MB]
[3.4]--3-5FlinkStandalone模式FlinkUI.mp4 [59.7 MB]
(3.2)--3-15Թ.pdf [32.7 KB]
? {17}--17Flinkݴ״̬״̬FlinkеӦ
(17.1)--17-14Թ.pdf [30.0 KB]
? {14}--14转Flink目实战之实时统之品(越Ka
(14.1)--14-8Թ.pdf [31.4 KB]
? {12}--12KafkaߣϢ&API
(12.1)--12-19Թ.pdf [30.9 KB]
[12.11]--12-11Kafka之Range.mp4 [63.6 MB]
[12.3]--12-3之为什么要.mp4 [23.0 MB]
? {7}--7转Flink目实战之一实时统之品
(7.1)--7-13Թ.pdf [28.9 KB]
[7.2]--7-2业谢Flink实时募芄.mp4 [49.3 MB]
[7.11]--7-11实指觳⑼称絛iff.mp4 [57.4 MB]
[4.10]--4-10远源实MySQL莸亩取.mp4 [105.3 MB]
(4.1)--4-11Թ.pdf [29.7 KB]
? {8}--8һҿKafkaɴKafkaܹ&
[8.6]--8-6图Kafka芄.mp4 [122.5 MB]
(8.1)--8-7Թ.pdf [24.2 KB]
[8.4]--8-4芙Kafka什么.mp4 [44.8 MB]
[8.3]--8-3通慕知Kafka什么.mp4 [88.2 MB]
[8.5]--8-5Kafka诖械牡使贸screenflow.mp4 [32.3 MB]ѧɣǰƽ
第1章 大厂技术首选高薪必备:揭开Flink的神秘面纱 第2章 批流一体丝滑开发体验:快速上手使用Flink进行编程 第3章 工欲善其事必先利其器:Flink部署及作业运行 第4章 快速便捷接入各种数据:Flink Data Source API编程 第5章 高效简洁数据处理方式:Flink Transformation API编程 第6章 处理结果吐出外部系统:Flink Sink API编程 第7章 玩转Flink项目实战之一:实时统计之商品分析 第8章 一起揭开Kafka神秘面纱:Kafka架构&核心术语 第9章 工欲善其事必先利其器:Kafka部署及监控 第10章 深度剖析Kafka生产者:消息发送流程&API编程&调优 第11章 深入剖析Kafka Broker:Kafka消息高效存储机制 第12章 深入剖析Kafka消费者:消息消费流程&API编程&调优 第13章 经典Kafka CP整合使用:Kafka整合外部系统 第14章 玩转Flink项目实战之二:实时统计之商品分析(对接Kafka) 第15章 时间对实时处理的影响:Flink时间语义及Window API篇 第16章 延迟乱序数据解决方案:Watermark在Flink中的使用 第17章 Flink容错核心状态管理:状态在Flink中的应用 第18章 玩转Flink项目实战之三:实时统计之数据大盘 第19章 Flink更加精简的开发方式:Flink Table & SQL API 第20章 数据采集神器Flink CDC:基于Flink CDC 进行实时数据采集 第21章 玩转Flink项目实战之四:实时统计之直播榜分析 第22章 战斗民族开源神器ClickHouse:揭开CH的神秘面纱 第23章 ClickHouse数据类型精讲:详解ClickHouse的各种数据类型的使用 第24章 ClickHouse内置函数精讲:详解ClickHouse的内置函数的使用 第25章 ClickHouse核心DDL&DML:库&表&视图的使用 第26章 ClickHouse核心引擎分析:各家族核心引擎使用及选型 第27章 ClickHouse元数据中心:元数据管理 第28章 经典ClickHouse整合Flink编程:整合Flink开发 第29章 玩转Flink项目实战之五:基于Flink和ClickHouse构建实时数据分析 第30章 揭开数据湖的神秘面纱:数据湖开源产品Hudi的使用 第31章 玩转Flink项目实战之六:基于Flink和Hudi的数据湖构建项目