VIP20
本课程属于：070-消息队列任务契约测试版本管理 Web后端与企业应用开发 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

消息队列集成测试：Kafka任务版本回滚与故障排查

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
Kafka核心概念回顾
Topic · Partition · Consumer Group
Kafka核心概念回顾
02
集成测试环境搭建
Docker Compose部署Ka… · Zookeeper配置 · 网络拓扑设计
集成测试环境搭建Docker
03
消息生产者集成测试
同步发送 · 异步发送 · 回调函数
消息生产者集成测…同步发送
04
消息消费者集成测试
自动提交与手动提交Offset · 消费组重平衡测试
消息消费者集成测…Offset
05
Kafka事务消息测试
Exactly-Once语义验证 · 事务协调器故障模拟
Kafka事务消息测试
06
幂等生产者测试
enable.idempotence… · 重复消息去重机制
幂等生产者测试enable.idemp…
07
消息顺序性保障测试
单分区顺序 · 多分区乱序场景模拟与断言
消息顺序性保障测…单分区顺序
08
消息积压与背压测试
消费速率限制 · 堆积告警阈值验证
消息积压背压测试
09
Kafka Connect集成测试
Source/Sink Connec… · Schema Registry兼容性
KafkaConnect
10
Kafka Streams集成测试
状态存储 · 窗口操作 · KTable与KStream拓扑验证
KafkaStreams
11
任务版本回滚概念
版本号管理 · 兼容性策略（向前/向后兼容）
任务版本回滚概念版本号管理
12
Schema版本回滚测试
Avro/Protobuf Sche… · 兼容性检查失败模拟
Schema版本回滚测试
13
生产者客户端版本回滚
旧版客户端与新Broker兼容性 · 协议降级测试
生产者客户端版本…Broker
14
消费者客户端版本回滚
Offset提交协议变化 · 重平衡策略回退
消费者客户端版本…Offset
15
Kafka Broker版本回滚
滚动升级与回滚步骤 · 日志格式版本兼容性
KafkaBroker
16
Kafka Connect插件版本回滚
Connector类加载隔离 · 版本冲突测试
KafkaConnect
17
Kafka Streams应用版本回滚
状态存储格式变更 · 拓扑节点兼容性
KafkaStreams
18
故障排查基础
日志级别动态调整 · JMX指标采集 · 关键监控指标解读
故障排查基础日志级别动态调整
19
生产者故障排查
TimeoutException · LeaderNotAvailable… · 网络分区模拟
生产者故障排查TimeoutExcep…
20
消费者故障排查
CommitFailedExcept… · IllegalGenerationE… · StickyAssignor问题
消费者故障排查CommitFailed…
21
Broker故障排查
磁盘空间不足 · Controller选举异常 · ISR收缩与OSR
Broker故障排查
22
网络故障排查
延迟 · 丢包 · 带宽瓶颈对生产消费的影响
网络故障排查延迟
23
消息丢失排查
acks=0/1/all配置 · min.insync.replica…
消息丢失排查acks
24
消息重复排查
幂等性失效 · 事务超时 · 消费者手动提交失败
消息重复排查幂等性失效
25
重平衡风暴排查
session.timeout.ms · max.poll.interval.… · 静态成员组
重平衡风暴排查session.time…
26
磁盘故障与数据恢复
日志段损坏 · 索引文件修复 · kafka-replay-log工具
磁盘故障数据恢复
27
集成测试框架设计
基于JUnit5 + Testcon…
集成测试框架设计JUnit5
28
混沌工程在Kafka测试中的应用
网络分区 · 节点宕机 · 磁盘IO延迟注入
Kafka混沌工程
29
CI/CD流水线集成
GitLab CI / Jenkin…
CI/CD流水线集成
30
综合实战案例
模拟生产环境故障 · 从问题发现 · 版本回滚到恢复验证的全流程演练
综合实战案例模拟生产环境故障