Flink Savepoint 状态恢复
Flink Savepoint 状态恢复是开发中常用的技术工具或方法。本文从实际应用出发介绍核心概念和操作步骤帮助读者快速上手并掌握关键技巧。
12
0
0
2026-07-13
Flink Watermark 事件时间处理
Flink Watermark 标记事件时间的进度到达窗口触发时间。乱序数据等待 Watermark 后才触发。allowedLateness 控制迟到。本文配置 Flink 处理延迟数据。
14
0
0
2026-07-11
Flink CDC 实时捕获数据库变更
Flink CDC 基于 Debezium 实时捕获数据库的 INSERT/UPDATE/DELETE。支持 MySQL/PostgreSQL/MongoDB。实时同步到数据湖或消息队列。本文用 Flink CDC 同步 MySQL 到 Kafka。
19
0
0
2026-07-10
Flink 流处理的基本概念
Flink 是分布式流处理引擎支持事件时间和处理时间。Window 按时间或数量聚合。Checkpoint 保证 Exactly-Once 语义。本文用实时计算用户点击量展示 Flink 的用法。
21
0
0
2026-07-08