VIP20
本课程属于：056-搜索服务尾延迟压测 Web后端与企业应用开发 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Kafka消费线程池参数调优缓解尾延迟压测波动

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
尾延迟与压测波动的定义 · 对Kafka消费端的影响 · 课程目标与学习路径
课程导论尾延迟
02
Kafka消费模型基础
Consumer Group · Partition分配策略 · Offset提交机制
Kafka消费模型基础
03
单线程消费的瓶颈
顺序处理 · 阻塞等待 · GC停顿导致的尾延迟放大
单线程消费的瓶颈顺序处理
04
线程池核心参数概览
corePoolSize · maximumPoolSize · keepAliveTime
线程池核心参数概…corePoolSize
05
corePoolSize调优
如何根据Partition数量与消息…
corePoolSize调优
06
maximumPoolSize调优
突发流量下的弹性伸缩上限 · 避免过度创建线程导致上下文切换
maximumPoolS…调优
07
workQueue选择与容量调优
SynchronousQueue v…
workQueue选择
08
RejectedExecutionHandler策略
AbortPolicy · CallerRunsPolicy · DiscardPolicy
RejectedExec…策略
09
keepAliveTime与线程回收
空闲线程回收对尾延迟的潜在影响 · 如何设置合理的超时时间
keepAliveTim…线程回收
10
线程池监控指标
activeCount · completedTaskCount · queueSize
线程池监控指标activeCount
11
压测方法论
使用Kafka自带的性能测试工具与自… · 模拟真实流量模式
压测方法论Kafka
12
尾延迟的度量
P99 · P999 · P9999延迟的计算与可视化
尾延迟的度量P99
13
波动性指标
标准差 · 变异系数 · 延迟抖动幅度
波动性指标标准差
14
参数调优第一步
确定基准线——固定Partition… · 消息大小 · 消费逻辑
参数调优第一步Partition
15
corePoolSize与Partition数的匹配实验
从1:1到1:N的对比测试
corePoolSizePartition
16
workQueue容量与背压
队列堆积如何导致延迟飙升 · 容量与线程数的平衡点
workQueue容量
17
预创建线程 vs 懒加载
预热线程池对首次消费延迟的影响
vs预创建线程
18
动态调整线程池
基于CPU使用率 · 队列深度 · 延迟指标的动态扩缩容策略
动态调整线程池CPU
19
避免线程饥饿
消费逻辑中的阻塞操作（如IO · RPC）对线程池的占用 · 如何分离IO线程与计算线程
避免线程饥饿IO
20
使用CompletableFuture异步化
将阻塞操作异步化 · 减少线程占用 · 降低尾延迟
CompletableF…使用
21
批量消费与线程池结合
max.poll.records与线…
批量消费线程池结合
22
GC对尾延迟的影响
Young GC与Full GC导致… · 如何通过线程池参数缓解
GC对尾延迟的影响
23
操作系统级调优
线程栈大小 · 文件描述符限制 · CPU亲和性对线程池性能的影响
操作系统级调优线程栈大小
24
压测波动案例分析
某业务线P99从50ms波动到500…
压测波动案例分析P99
25
参数调优工具
基于JMH的微基准测试框架 · 快速验证线程池参数组合
参数调优工具JMH
26
自动化调优
使用贝叶斯优化或网格搜索自动寻找最优…
自动化调优使用贝叶斯优化或…
27
生产环境灰度验证
A/B测试 · 金丝雀发布 · 逐步调整线程池参数
生产环境灰度验证A/B
28
监控与告警体系
Prometheus + Grafa…
监控告警体系
29
常见陷阱与反模式
线程池过大导致OOM · 队列无限增长 · 拒绝策略不当
常见陷阱反模式
30
课程总结与最佳实践
一套可复用的Kafka消费线程池调优…
课程总结最佳实践