VIP20
本课程属于：049-API设计治理Kafka堆积诊断 Web后端与企业应用开发 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

KafkaAPI Kafka诊断消息堆积诊断

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
Kafka基础回顾
Kafka核心概念（Topic · Partition · Offset
Kafka基础回顾
02
Kafka API概览
Producer API · Consumer API · AdminClient API的功能…
KafkaAPI
03
Kafka Producer API详解
创建Producer · 配置参数（bootstrap.ser… · key.serializer
KafkaProducer
04
Kafka Producer高级特性
分区策略（Partitioner） · 消息可靠性（acks · retries）
KafkaProducer
05
Kafka Consumer API详解
创建Consumer · 订阅Topic · 拉取消息（poll）
KafkaConsumer
06
Kafka Consumer Group与再均衡
Group协调器 · 分区分配策略（Range · RoundRobin
KafkaConsumer
07
Kafka AdminClient API
管理Topic（创建 · 删除 · 查看）
KafkaAdminClient
08
Kafka消息堆积定义与危害
什么是消息堆积 · 堆积对系统延迟的影响 · 堆积导致的数据丢失风险
Kafka消息堆积定义
09
消息堆积的常见原因分析（上）
生产者发送过快 · 消费者处理能力不足 · 分区数不合理
消息堆积的常见原…生产者发送过快
10
消息堆积的常见原因分析（下）
消费者阻塞（GC · 网络 · 业务逻辑）
消息堆积的常见原…GC
11
消息堆积诊断工具与命令
kafka-consumer-gro… · 查看Lag · 查看消费者状态
消息堆积诊断工具命令
12
消息堆积诊断工具与命令
JMX监控指标（KafkaConsu… · Prometheus+Grafana…
消息堆积诊断工具命令
13
消息堆积诊断工具与命令
Kafka内置API（describ… · listConsumerGroupO…
消息堆积诊断工具命令
14
消息堆积诊断实战
使用AdminClient API获…
消息堆积诊断实战AdminClient
15
消息堆积诊断实战
使用Consumer API自定义L…
消息堆积诊断实战Consumer
16
消息堆积诊断实战
通过JMX实时监控消费者Lag变化
消息堆积诊断实战JMX
17
消息堆积诊断实战
分析消费者日志与线程堆栈定位阻塞点
消息堆积诊断实战分析消费者日志
18
消息堆积诊断实战
使用Kafka Lag Export…
消息堆积诊断实战Kafka
19
消息堆积诊断实战
基于时间戳的Lag回溯分析
消息堆积诊断实战Lag
20
消息堆积诊断实战
多消费者组Lag对比分析
消息堆积诊断实战Lag
21
消息堆积诊断实战
分区级别Lag细粒度诊断
消息堆积诊断实战Lag
22
消息堆积诊断实战
结合Kafka UI（如CMAK · Kafka Manager）可视化诊…
消息堆积诊断实战Kafka
23
消息堆积解决方案
增加消费者数量与分区数 · 优化消费者处理逻辑
消息堆积解决方案增加消费者数量
24
消息堆积解决方案
调整Consumer参数（max.p… · fetch.max.bytes · session.timeout.ms…
消息堆积解决方案Consumer
25
消息堆积解决方案
使用异步处理与批量消费提升吞吐
消息堆积解决方案使用异步处理
26
消息堆积解决方案
合理设置偏移量提交策略（自动提交 v…
消息堆积解决方案合理设置偏移量提…
27
消息堆积解决方案
引入消息队列背压机制与限流
消息堆积解决方案引入消息队列背压…
28
消息堆积解决方案
使用Kafka Streams或Sp…
消息堆积解决方案Kafka
29
消息堆积诊断与治理最佳实践
监控告警体系 · 自动化诊断脚本 · 应急预案
消息堆积诊断治理最佳实践
30
综合实战案例
从零搭建Kafka消息堆积诊断系统（…
综合实战案例Kafka