VIP20
本课程属于：077-分布式事务压测场景库 Web后端与企业应用开发 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Kafka消息可靠性测试与分布式事务压测实践

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
Kafka在分布式系统中的核心地位 · 消息可靠性为何是生命线 · 分布式事务的挑战与压测的必要性
课程导论Kafka
02
Kafka基础架构回顾
Producer · Broker · Consumer
Kafka基础架构回顾
03
消息可靠性基石
ACKS参数深度解析（acks=0 · 1 · all）
消息可靠性基石ACKS
04
生产者可靠性
幂等性（enable.idempot… · 事务性生产者（transaction… · 常见发送失败场景
生产者可靠性enable.idemp…
05
消费者可靠性
消费位移提交机制（自动/手动） · enable.auto.commit · 消费幂等性设计
消费者可靠性消费位移提交机制
06
Broker端可靠性
Leader选举与ISR收缩 · 日志同步机制（HW/LEO） · 数据刷盘策略（flush.ms/fl…
Broker端可靠性
07
数据持久化与恢复
日志段（Log Segment）结构 · 索引文件（.index/.timei… · 日志清理策略（delete/comp…
数据持久化恢复
08
副本机制与高可用
Replica分配策略 · Follower同步滞后判定 · 优先副本选举
副本机制高可用
09
消息丢失场景模拟
Producer发送失败未重试 · Broker宕机未完成同步 · Consumer提交位移过早导致数据…
消息丢失场景模拟Producer
10
消息重复场景模拟
Producer重试导致重复 · Consumer rebalance… · 事务回滚不彻底导致重复
消息重复场景模拟Producer
11
消息乱序场景模拟
Partition内乱序原因（重试/… · 全局乱序与局部乱序 · 如何保证顺序消费
消息乱序场景模拟Partition
12
可靠性测试环境搭建
Docker Compose部署多B… · JMX监控配置 · Prometheus+Grafana…
可靠性测试环境搭…Docker
13
可靠性测试工具选型
kafka-producer-per… · kafka-consumer-per… · 自定义Java/Python测试脚本
可靠性测试工具选…kafka-produc…
14
可靠性测试用例设计
正常流量测试 · Broker宕机测试 · 网络分区测试
可靠性测试用例设…正常流量测试
15
可靠性测试执行与结果分析
如何验证Exactly-Once · 如何统计丢失率/重复率 · 如何定位瓶颈
可靠性测试执行结果分析
16
分布式事务基础理论
ACID与BASE · CAP定理与PACELC · 两阶段提交（2PC）与三阶段提交（3…
分布式事务基础理…ACID
17
Kafka事务原理
事务协调器（Transaction… · 事务日志（__transaction… · 事务状态机
Kafka事务原理
18
Kafka事务API实战
initTransactions · beginTransaction · sendOffsetsToTrans…
KafkaAPI
19
事务性生产者与消费者配合
消费-处理-生产模式（EOS） · 事务内消费位移提交 · 跨Topic原子写入
事务性生产者消费者配合
20
分布式事务常见模式
TCC模式 · Saga模式 · 本地消息表
分布式事务常见模…TCC
21
分布式事务压测目标
吞吐量 · 延迟 · 成功率
分布式事务压测目…吞吐量
22
压测工具选型与配置
JMeter + Kafka插件 · Locust + kafka-pyt… · wrk2
压测工具选型配置
23
压测场景设计
纯消息写入压测 · 事务性写入压测 · 消费-处理-生产全链路压测
压测场景设计纯消息写入压测
24
压测指标采集
端到端延迟（P99/P999） · 事务提交成功率 · 每秒事务数（TPS）
压测指标采集P99/P999
25
压测结果分析与调优
调整batch.size/linge… · 调整事务超时时间 · 调整分区数
压测结果分析调优
26
可靠性+事务联合压测
在压测中注入故障（Chaos Eng… · 验证事务在故障下的原子性
可靠性+事务联合…Chaos
27
生产环境最佳实践
监控告警配置（事务超时/ISR收缩） · 日志审计 · 容量规划
生产环境最佳实践ISR
28
常见问题与排障
事务超时导致hang · Coordinator负载不均 · __transaction_stat…
常见问题排障
29
案例实战
金融支付场景的可靠性保障 · 订单系统的分布式事务设计 · 实时风控的Exactly-Once实…
案例实战金融支付场景的可…
30
课程总结与展望
Kafka未来版本可靠性增强（KIP… · 与Pulsar/RocketMQ的可… · 云原生时代的演进趋势
课程总结Kafka