VIP20
本课程属于：016-报表导出服务模块边界拆分 Web后端与企业应用开发 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

报表导出模块边界：Kafka死信队列故障诊断与排查实战

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
死信队列概念
什么是死信队列 · 死信队列在消息系统中的角色 · 死信与普通消息的区别
死信队列概念什么是死信队列
02
Kafka消息投递语义
At-most-once · At-least-once · Exactly-once语义及其对死…
Kafka消息投递语义
03
Kafka重试机制
生产者重试 · 消费者重试 · 重试次数与间隔配置
Kafka重试机制
04
死信产生原因
消息格式错误 · 业务处理异常 · 超时
死信产生原因消息格式错误
05
死信队列架构设计
死信主题(DLQ Topic)设计 · 分区策略 · 消息路由规则
死信队列架构设计DLQ
06
死信消息格式
原始消息封装 · 错误元数据 · 时间戳
死信消息格式原始消息封装
07
死信生产者配置
acks · retries · max.in.flight.requ…
死信生产者配置acks
08
死信消费者配置
enable.auto.commit · auto.offset.reset · max.poll.records
死信消费者配置enable.auto.…
09
死信主题生命周期管理
消息保留策略 · 压缩策略 · 过期清理
死信主题生命周期…消息保留策略
10
死信消息重处理
手动重放 · 自动重试 · 死信回捞
死信消息重处理手动重放
11
死信监控与告警
死信主题消息堆积监控 · 消费延迟告警 · 异常率统计
死信监控告警
12
死信可视化工具
Kafka Manager · Kafka Tool · Confluent Control…
死信可视化工具Kafka
13
死信与幂等性
幂等生产者 · 幂等消费者 · 去重机制
死信幂等性
14
死信与事务
Kafka事务机制 · 原子写入 · 死信与事务回滚
死信事务
15
死信与Schema Registry
Avro/Protobuf/JSON… · 序列化错误处理
SchemaRegistry
16
死信与Connect框架
Kafka Connect死信配置 · Sink Connector错误处理 · DLQ Sink
Connect死信
17
死信与Streams框架
Kafka Streams死信处理 · Processor API异常处理 · DSL死信路由
Streams死信
18
死信与Spring Kafka
@RetryableTopic · @DltHandler · DefaultErrorHandle…
SpringKafka
19
死信与Kafka Clients原生API
自定义ErrorHandler · DeadLetterPublishi…
KafkaClients
20
死信与云服务
Confluent Cloud死信 · AWS MSK死信 · Azure Event Hubs死信…
死信云服务
21
故障排查基础
Kafka日志分析 · JMX指标 · 线程Dump
故障排查基础Kafka
22
生产者故障排查
超时 · Leader选举 · 网络分区
生产者故障排查超时
23
消费者故障排查
Rebalance风暴 · 消费停滞 · Offset提交失败
消费者故障排查Rebalance
24
Broker故障排查
磁盘满 · 文件句柄耗尽 · Controller选举
Broker故障排查
25
网络故障排查
带宽瓶颈 · 延迟抖动 · 连接泄漏
网络故障排查带宽瓶颈
26
死信队列故障排查
死信主题写入失败 · 死信消息丢失 · 死信消费死循环
死信队列故障排查死信主题写入失败
27
性能调优
批量大小 · 压缩算法 · 缓冲区配置
性能调优批量大小
28
数据一致性排查
消息重复 · 消息乱序 · 事务状态不一致
数据一致性排查消息重复
29
监控体系搭建
Prometheus + Grafa… · Kafka Exporter · Burrow
监控体系搭建Prometheus
30
最佳实践与案例
电商订单死信处理 · 日志采集死信恢复 · 金融交易死信补偿
最佳实践案例