Jackeyzhe

文章/答案/技术大牛

发布

LV2

发表了文章 4天前2026-01-28 12:20:12

从零学习Kafka：集群架构和基本概念

在前文中，我们从源码层面介绍了 Flink 的 Kafka Connector 的实现。从本文开始，我们的目标也正式从 Flink 过渡到 Kafka。

Jackeyzhe 4天前2026-01-28 12:20:13

集群、架构、模型、系统、kafka

发表了文章 4天前2026-01-28 12:19:41

跟着AI学习Kafka

本文是由 Gemini 生成的 Kafka 学习路径。Gemini 中有一个学习辅导的工具，它可以通过互动问答的形式帮助你由浅入深的学习一个知识点，个人感觉还是...

Jackeyzhe 4天前2026-01-28 12:19:42

数据、原理、kafka、管理、设计

发表了文章 10天前2026-01-22 14:07:37

Flink源码阅读：Kafka Connector

在介绍 Kafka Connector 之前，我们先来看一下在 Flink 中是如何支持自定义 Source 和 Sink 的。我们来看一张 Flink 官方文...

Jackeyzhe 10天前2026-01-22 14:07:37

flink、接口、数据、源码阅读、kafka

发表了文章 10天前2026-01-22 14:07:23

Flink源码阅读：Mailbox线程模型

在以前的线程模型中，Flink 通过 checkpointLock 来隔离保证不同线程在修改内部状态时的正确性。通过 checkpointLock 控制并发会在...

Jackeyzhe 10天前2026-01-22 14:07:23

队列、模型、线程、源码阅读、flink

发表了文章 11天前2026-01-21 07:56:09

Flink源码阅读：Mailbox线程模型

在以前的线程模型中，Flink 通过 checkpointLock 来隔离保证不同线程在修改内部状态时的正确性。通过 checkpointLock 控制并发会在...

Jackeyzhe 11天前2026-01-21 07:56:09

flink、大数据

发表了文章 20天前2026-01-12 13:37:33

Flink源码阅读：JobManager的HA机制

JobManager 在 Flink 集群中发挥着重要的作用，包括任务调度和资源管理等工作。如果 JobManager 宕机，那么整个集群的任务都将失败。为了解...

Jackeyzhe 20天前2026-01-12 13:37:33

flink、对象、服务、源码阅读、存储

发表了文章 20天前2026-01-12 13:37:26

Flink源码阅读：Netty通信

前文中我们了解了 Flink 的数据交互过程，上游的 Task 将数据写入到 ResultSubpartition 的 buffers 队列中。下游的 Task...

Jackeyzhe 20天前2026-01-12 13:37:26

netty、数据、通信、源码阅读、flink

发表了文章 20天前2026-01-12 13:37:15

Flink源码阅读：Task数据交互

经过前面的学习，Flink 的几个核心概念相关的源码实现我们已经了解了。本文我们来梳理 Task 的数据交互相关的源码。

Jackeyzhe 20天前2026-01-12 13:37:15

队列、数据、源码阅读、flink、task

发表了文章 22天前2026-01-09 20:15:32

Flink源码阅读：Task数据交互

经过前面的学习，Flink 的几个核心概念相关的源码实现我们已经了解了。本文我们来梳理 Task 的数据交互相关的源码。

Jackeyzhe 22天前2026-01-09 20:15:31

flink、大数据

发表了文章 2025-12-312025-12-31 11:41:56

Flink源码阅读：双流操作

通过Flink学习笔记：多流 Join一文的介绍，我们知道 Flink 有三种数据关联的方式，分别是 Window Join、Interval Join 和 C...

Jackeyzhe 2025-12-312025-12-31 11:41:56

flink、string、数据、源码、源码阅读

发表了文章 2025-12-312025-12-31 11:41:47

Flink源码阅读：窗口

前文我们梳理了 Watermark 相关的源码，Watermark 的作用就是用来触发窗口，本文我们就一起看一下窗口相关的源码。

Jackeyzhe 2025-12-312025-12-31 11:41:47

数据、源码、源码阅读、flink、window

发表了文章 2025-12-312025-12-31 11:41:40

Flink源码阅读：Watermark机制

前面我们已经梳理了 Flink 状态和 Checkpoint 相关的源码。从本文开始，我们再来关注另外几个核心概念，即时间、Watermark 和窗口。

Jackeyzhe 2025-12-312025-12-31 11:41:40

watermark、变量、源码、源码阅读、flink

发表了文章 2025-12-262025-12-26 08:05:17

Flink源码阅读：Watermark机制

前面我们已经梳理了 Flink 状态和 Checkpoint 相关的源码。从本文开始，我们再来关注另外几个核心概念，即时间、Watermark 和窗口。

Jackeyzhe 2025-12-262025-12-26 08:05:17

flink、大数据

发表了文章 2025-12-232025-12-23 08:10:25

Flink源码阅读：集群启动

前文中，我们已经了解了 Flink 的三种执行图是怎么生成的。今天继续看一下 Flink 集群是如何启动的。

Jackeyzhe 2025-12-232025-12-23 08:10:25

服务、集群、连接、源码阅读、flink

发表了文章 2025-12-232025-12-23 08:10:07

Flink源码阅读：如何生成ExecutionGraph

今天我们一起来了解 Flink 最后一种执行图，ExecutionGraph 的执行过程。

Jackeyzhe 2025-12-232025-12-23 08:10:07

int、遍历、并发、源码阅读、flink

发表了文章 2025-12-232025-12-23 08:09:13

Flink源码阅读：如何生成JobGraph

前文我们介绍了 Flink 的四种执行图，并且通过源码了解了 Flink 的 StreamGraph 是怎么生成的，本文我们就一起来看下 Flink 的另一种执...

Jackeyzhe 2025-12-232025-12-23 08:09:14

配置、数据、源码阅读、flink、连接

发表了文章 2025-12-232025-12-23 08:07:50

Flink源码阅读：如何生成StreamGraph

Flink 中有四种执行图，分别是 StreamGraph、JobGraph、ExecutionGraph 和 Physical Graph。今天我们来看下我们...

Jackeyzhe 2025-12-232025-12-23 08:07:50

源码阅读、flink、class、函数、序列化

发表了文章 2025-12-232025-12-23 08:07:14

Flink学习笔记：反压

反压是流式系统中关于数据处理能力的动态反馈机制，并且是从下游到上游的反馈，一般发生在上游节点的生产速度大于下游节点的消费速度的情况。

Jackeyzhe 2025-12-232025-12-23 08:07:14

flink、部署、数据、线程、学习笔记

发表了文章 2025-12-232025-12-23 07:55:04

Flink源码阅读：如何生成JobGraph

前文我们介绍了 Flink 的四种执行图，并且通过源码了解了 Flink 的 StreamGraph 是怎么生成的，本文我们就一起来看下 Flink 的另一种执...

Jackeyzhe 2025-12-232025-12-23 07:55:04

flink、大数据

发表了文章 2025-12-222025-12-22 07:57:58

Flink源码阅读：如何生成StreamGraph

Flink 中有四种执行图，分别是 StreamGraph、JobGraph、ExecutionGraph 和 Physical Graph。今天我们来看下我们...

Jackeyzhe 2025-12-222025-12-22 07:57:58

flink、大数据

12 3 4 5 6 7 下一页

个人简介

暂未填写公司和职称
公众号：代码洁癖患者，半栈工程师，后端其他语言也能玩一点，最近学习Rust，欢迎交流
暂未填写技能专长
暂未填写学校和专业
https://jackeyzhe.github.io/
北京
加入社区时间：2018-11-02

个人成就

获得 224 次赞同
文章被阅读 95.1K 次

关注了：1关注者：17

Jackeyzhe

从零学习Kafka：集群架构和基本概念

跟着AI学习Kafka

Flink源码阅读：Kafka Connector

Flink源码阅读：Mailbox线程模型

Flink源码阅读：Mailbox线程模型

Flink源码阅读：JobManager的HA机制

Flink源码阅读：Netty通信

Flink源码阅读：Task数据交互

Flink源码阅读：Task数据交互

Flink源码阅读：双流操作

Flink源码阅读：窗口

Flink源码阅读：Watermark机制

Flink源码阅读：Watermark机制

Flink源码阅读：集群启动

Flink源码阅读：如何生成ExecutionGraph

Flink源码阅读：如何生成JobGraph

Flink源码阅读：如何生成StreamGraph

Flink学习笔记：反压

Flink源码阅读：如何生成JobGraph

Flink源码阅读：如何生成StreamGraph

个人简介

个人成就

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐