VIP20
本课程属于：006-后端发布拓扑蓝图 Web后端与企业应用开发 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Kafka消息重试在后端发布拓扑中的故障恢复策略设计

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
Kafka消息重试与故障恢复的背景 · 课程目标与受众 · 整体知识图谱
课程导论Kafka
02
Kafka核心概念回顾
Topic · Partition · Offset
Kafka核心概念回顾
03
消息投递语义
At-most-once · At-least-once · Exactly-once 的定义与适…
消息投递语义At-most-once
04
消息丢失场景分析
生产者丢失 · Broker丢失 · 消费者丢失的根因与影响
消息丢失场景分析生产者丢失
05
消息重复场景分析
重复生产 · 重复消费 · Rebalance导致的重复处理
消息重复场景分析重复生产
06
重试策略基础
同步重试 vs 异步重试 · 指数退避算法 · 最大重试次数
重试策略基础vs
07
死信队列（DLQ）设计
DLQ的Topic结构 · 消息格式 · 生命周期管理
DLQ死信队列
08
重试Topic设计
重试Topic的分区策略 · TTL设置 · 与主Topic的隔离机制
Topic重试
09
消费者侧重试架构
阻塞重试 · 非阻塞重试 · 重试队列与主消费线程的解耦
消费者侧重试架构阻塞重试
10
生产者侧重试机制
acks参数 · retries参数 · 幂等生产者
生产者侧重试机制acks
11
幂等性保障
enable.idempotence… · 序列号与Producer ID · 去重边界
幂等性保障enable.idemp…
12
事务性消息
Kafka事务API · 事务协调器 · 原子性写入多分区
事务性消息Kafka
13
发布拓扑（Publish Topology）概念
事件驱动架构中的发布节点 · 订阅节点 · 路由规则
PublishTopology
14
拓扑中的故障类型
节点宕机 · 网络分区 · 消息积压
拓扑故障类型
15
故障检测机制
心跳检测 · 消费者Lag监控 · 超时与重试触发条件
故障检测机制心跳检测
16
重试风暴（Retry Storm）问题
级联重试 · 资源耗尽 · 雪崩效应
RetryStorm
17
重试限流与熔断
令牌桶算法 · 滑动窗口 · 断路器模式在重试中的应用
重试限流熔断
18
状态存储与恢复点
Offset持久化 · 本地状态快照 · 外部状态存储（Redis/DB）
状态存储恢复点
19
Exactly-Once 在拓扑中的实现
Kafka Streams的EOS · 事务边界与状态存储
Exactly-Once拓扑
20
多级重试架构
本地重试 · 远程重试 · 全局重试协调器
多级重试架构本地重试
21
重试消息的排序与去重
时间戳排序 · 全局ID去重 · 分区内有序性保证
重试消息的排序去重
22
监控与告警
重试次数指标 · DLQ消息量 · 重试延迟
监控告警
23
故障恢复演练
模拟Broker宕机 · 模拟消费者崩溃 · 模拟网络抖动
故障恢复演练Broker
24
重试策略配置中心
动态配置 · 灰度发布 · 策略热更新
重试策略配置动态配置
25
案例研究1
电商订单系统的重试与故障恢复设计
案例研究1电商订单系统的重…
26
案例研究2
金融支付系统的Exactly-onc…
案例研究2Exactly-onc
27
案例研究3
IoT设备数据上报拓扑中的重试与去重
案例研究3IoT
28
性能调优
重试线程池大小 · 批量重试 · 异步回调优化
性能调优重试线程池大小
29
安全与合规
重试消息的敏感数据脱敏 · 审计日志 · 合规保留
安全合规
30
课程总结与最佳实践
设计原则 · 常见陷阱 · 未来演进方向（Kafka 4.0展望…
课程总结最佳实践