订阅更新

实时计算开发

Flink 的状态、Checkpoint、时间语义是地基，Kafka 的可靠性是另一半；最后落到实时数仓、CDC 和线上排错。

2 周48 题适合：投 Flink / Kafka / 实时数仓岗位 还没开始

从第 1 题开始 随机抽一题自测

1Flink 核心机制

10 题

Checkpoint 和 Exactly-Once 一定会被追问到底，要能画出 Barrier 的流动。

  1. 05-01 Flink作业跑着跑着突然重启了——Checkpoint到底怎么工作的？ Flink
  2. 007 Flink 的 Exactly-Once 是怎么实现的？ Flink
  3. 023 Flink Checkpoint 和 Savepoint 有什么区别？ Flink
  4. 064 Flink Barrier 对齐和非对齐 Checkpoint 有什么区别？ Flink
  5. 207 Flink 增量 Checkpoint 是怎么工作的？ Flink
  6. 039 Flink Keyed State 和 Operator State 有什么区别？ Flink
  7. 149 Flink State Backend 怎么选？ Flink
  8. 014 Flink Watermark 和迟到数据怎么处理？ Flink
  9. 05-02 数据延迟了5分钟才到——Watermark和Event Time怎么处理乱序数据？ Flink
  10. 028 Flink 窗口怎么选？滚动、滑动、会话有什么区别？ Flink

2Kafka 可靠性与消费

10 题

「不丢、不重、有序」三个问题各准备一段完整回答。

  1. 013 Kafka 如何保证消息不丢失？ Kafka
  2. 040 Kafka acks 和 min.insync.replicas 怎么配置？ Kafka
  3. 026 Kafka ISR、HW 和 LEO 分别是什么？ Kafka
  4. 022 Kafka 出现重复消费，怎么保证幂等？ Kafka
  5. 055 Kafka 幂等 Producer 和事务 Producer 有什么区别？ Kafka
  6. 032 Kafka 如何保证消息顺序？ Kafka
  7. 004 Kafka 消息积压了，你怎么排查？ Kafka
  8. 015 Kafka Consumer 频繁 Rebalance，你怎么排查？ Kafka
  9. 035 Kafka Offset 怎么提交？自动还是手动？ Kafka
  10. 170 Kafka KRaft 为什么替代 ZooKeeper？ Kafka

3Flink 排错与调优

11 题

反压、Checkpoint 失败、状态过大，按「现象 → 指标 → 原因 → 解法」讲。

  1. 003 Flink 任务出现反压，你怎么排查？ Flink
  2. 005 Flink Checkpoint 经常失败，你怎么排查？ Flink
  3. 266 Flink Checkpoint 太慢，怎么区分对齐慢和快照慢？ Flink
  4. 016 Flink State 太大，你怎么优化？ Flink
  5. 192 Flink State TTL 怎么配置？为什么数据不会立即删除？ Flink
  6. 216 Flink 数据倾斜怎么排查和治理？ Flink
  7. 031 Flink 并行度怎么设置？ Flink
  8. 276 Flink 有状态任务怎么扩容？并行度和最大并行度有什么区别？ Flink
  9. 287 Flink Watermark 已经推进，窗口为什么还没有输出？ Flink
  10. 256 Flink 空闲分区为什么会卡住 Watermark？withIdleness 怎么用？ Flink
  11. 05-11 Flink作业OOM了——内存模型和调优思路 Flink

4实时数仓与 CDC

12 题

维表关联和流批一致性是实时数仓题的核心。

  1. 020 Flink 维表 Join 怎么设计？ Flink
  2. 178 Flink Temporal Join 如何关联版本化维表？ Flink
  3. 169 Flink SQL Changelog 是什么？ Flink
  4. 347 Flink SQL 声明 PRIMARY KEY 就会自动去重吗？NOT ENFORCED 是什么意思？ Flink
  5. 088 CDC 增量同步如何保证不丢不重？ 数据开发与治理
  6. 227 CDC 全量快照和增量日志怎么无缝衔接？ 数据开发与治理
  7. 05-16 实时数仓分层怎么做？Flink+Kafka+Doris的架构设计 Flink
  8. 05-17 Flink CDC直接读MySQL Binlog——替代Canal的新方案 Flink
  9. 20-03 实时数仓也要分层吗？跟离线分层完全不一样——实时分层怎么做？ 数仓建模
  10. 20-06 实时和离线的数据对不上，业务方炸了——口径一致性怎么保证？ 数仓建模
  11. 090 离线数仓和实时数仓如何保证数据一致？ 数仓建模
  12. 06-08 FlinkCDC → Kafka → Flink → Doris，实时数仓这条链路怎么设计最稳？ Kafka

5讲出你的实时项目

5 题

准备好延迟、吞吐、数据量三个数字。

  1. 05-20 请描述一个你用Flink做过的项目 Flink
  2. 3 实时项目怎么讲才能展示深度：实时项目表达模板 项目实战表达 13 讲
  3. 12 实时数仓面试官追问 Exactly-Once：怎么接住追问 项目实战表达 13 讲
  4. 20-15 Flink作业挂了重启后数据重复了——Exactly-Once到底怎么保证？ 数仓建模
  5. 20-16 实时大屏要秒级刷新，但Flink窗口是1分钟——怎么做到'看起来实时'？ 数仓建模

其他路线：面试前 3 天冲刺离线数仓开发湖仓与 OLAP手写 SQL 必刷AI / 大模型数据岗数据治理与平台项目表达与行为面