Kafka 核心技术与实战 Mapping

• 00 开篇词 为什么要学习Kafka？ done

1 入门

• 01 消息引擎系统ABC done
• 02 一篇文章带你快速搞定Kafka术语 done
• 03 Kafka只是消息引擎系统吗？ done
• 04 我应该选择哪种Kafka？ done
• 05 聊聊Kafka的版本号

2 基础使用

• 06 Kafka线上集群部署方案怎么做？
• 07 最最最重要的集群参数配置（上）🧾
• 08 最最最重要的集群参数配置（下）🧾

3 客户端实践及原理剖析 (14 讲)

• 09 生产者消息分区机制原理剖析 done
  → Kafka 生产者分区策略 & 消息分区分配策略
• 10 生产者压缩算法面面观 done
  → Kafka 消息什么时候适合数据压缩？有哪些压缩方法？
• 11 无消息丢失配置怎么实现？ done
  → Kafka 消息丢失的原因？怎么验证？怎么解决？(理论+业务角度)
• 12 客户端都有哪些不常见但是很高级的功能？
  → 怎么使用 Kafka 拦截器？应用场景？
• 13 Java生产者是如何管理TCP连接的？
• 14 幂等生产者和事务生产者是一回事吗
  → 哪些消息交付语义？ACK机制？
• 15 消费者组到底是什么？ done
  → 消费者组特性、Consumer Offset 保存、Rebalance
• 16 揭开神秘的“位移主题”面纱 done
  → __consumer_offsets Topic
• 17 消费者组重平衡能避免吗？ done
  → Coordinator、Rebalance 弊端、如何避免
• 18 Kafka中位移提交那些事儿 done
  → 自动/手动提交，以及对应丢失&重复消费问题；同步/异步提交。
• 19 CommitFailedException异常怎么处理？
• 20 多线程开发消费者实例
• 21 Java 消费者是如何管理TCP连接的_
• 22 消费者组消费进度监控都怎么实现？
  监控消费堆积方式

4 深入 Kafka 内核 (5 讲)

• 23 Kafka副本机制详解 done
• 24 请求是怎么被处理的？
• 25 消费者组重平衡全流程解析 done
• 26 你一定不能错过的Kafka控制器 done
  → Kafka 控制器是什么？作用？
  → Kafka 控制器是怎么选举的？
  → Kafka 控制器是如何监听 Broker 变化的？
• 27 关于高水位和Leader Epoch的讨论 done

5 管理与监控 (12 讲)

• 28 主题管理知多少(命令行操作)？
• 29 Kafka动态配置了解下？
• 30 怎么重设消费者组位移？⭐️
• 31 常见工具脚本大汇总 🧾
• 32 KafkaAdminClient：Kafka的运维利器 🧾
• 33 Kafka认证机制用哪家？ 🧾
• 34 云环境下的授权该怎么做？ 🧾
• 35 跨集群备份解决方案MirrorMaker 🧾
• 36 你应该怎么监控Kafka？⭐️ 🧾
• 37 主流的Kafka监控框架 🧾
• 38 调优Kafka，你做到了吗？⭐️ 🧾
• 39 从0搭建基于Kafka的企业级实时日志流处理平台 🧾

6 高级 Kafka 应用之流处理 (3 讲)

• 40 Kafka Streams与其他流处理平台的差异在哪里？
• 41 Kafka Streams DSL开发实例
• 42 Kafka Streams在金融领域的应用

7 特别放送 (2 讲)

• 加餐 搭建开发环境、阅读源码方法、经典学习资料大揭秘
• 用户故事 黄云：行百里者半九十 done

8 结束语 (1 讲)

• 结束语 以梦为马，莫负韶华！ done