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

消息队列集成测试：Kafka状态回溯与版本适配

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
Kafka基础回顾
Kafka核心概念（Topic · Partition · Offset
Kafka基础回顾
02
集成测试概述
集成测试定义 · 与单元测试的区别 · 消息队列集成测试的挑战与目标
集成测试概述集成测试定义
03
测试环境搭建
Docker Compose部署Ka… · Zookeeper配置 · 网络与端口规划
测试环境搭建Docker
04
Kafka客户端版本适配
Java/Python客户端版本差异 · API兼容性矩阵 · 版本选择策略
Kafka客户端版本适配
05
生产者集成测试
同步/异步发送测试 · acks配置验证 · 重试机制与幂等性测试
生产者集成测试同步
06
消费者集成测试
订阅模式测试 · 手动/自动提交偏移量 · 再均衡监听器测试
消费者集成测试订阅模式测试
07
消息序列化与反序列化测试
Avro/JSON/Protobuf… · Schema Registry集成测…
消息序列化反序列化测试
08
事务消息测试
Exactly-Once语义验证 · 事务协调器测试 · 事务超时与回滚测试
事务消息测试Exactly-Once
09
幂等性生产者测试
幂等性开启验证 · 序列号冲突处理 · Broker端去重测试
幂等性生产者测试幂等性开启验证
10
消息顺序性测试
单分区顺序保证 · 多分区顺序挑战 · 分区键设计测试
消息顺序性测试单分区顺序保证
11
消息回溯机制
Offset重置策略（earlies… · Seek方法测试 · 时间戳回溯
消息回溯机制Offset
12
状态回溯场景测试
消费者故障恢复 · 数据重放 · 历史数据校验测试
状态回溯场景测试消费者故障恢复
13
Kafka Streams状态回溯
状态存储恢复 · KTable与KStream回溯 · 变更日志主题测试
KafkaStreams
14
Kafka Connect集成测试
Source/Sink连接器测试 · 单次模式（Exactly Once）… · 错误处理测试
KafkaConnect
15
多版本兼容性测试
客户端与Broker版本交叉测试 · 协议版本协商 · 特性兼容性矩阵
多版本兼容性测试Broker
16
升级与迁移测试
滚动升级测试 · 协议版本升级 · 消息格式迁移测试
升级迁移测试
17
安全集成测试
SSL/TLS加密测试 · SASL认证（PLAIN/SCRAM… · ACL权限测试
安全集成测试SSL/TLS
18
性能基准测试
吞吐量测试 · 延迟测试 · 分区数对性能影响测试
性能基准测试吞吐量测试
19
压力测试与稳定性
高并发生产消费测试 · Broker故障恢复测试 · 磁盘满场景测试
压力测试稳定性
20
数据一致性测试
生产者-消费者端到端一致性验证 · 幂等性与事务联合测试
数据一致性测试生产者
21
死信队列与错误处理
重试队列设计 · 死信主题测试 · 错误消息格式验证
死信队列错误处理
22
日志压缩与清理测试
Log Compaction策略测试 · 删除策略测试 · 墓碑消息测试
日志压缩清理测试
23
配额与限流测试
生产者/消费者配额测试 · 请求限流验证 · 客户端节流行为测试
配额限流测试
24
监控与指标集成测试
JMX指标验证 · Prometheus/Grafana… · 关键指标阈值测试
监控指标集成测试
25
测试框架选型
JUnit5/Testcontain… · MockProducer/MockC…
测试框架选型JUnit5/Testc…
26
Testcontainers集成
Kafka容器化测试 · 动态创建Topic · 容器生命周期管理
Testcontaine…集成
27
契约测试
Schema兼容性契约 · 消息格式契约 · 消费者驱动契约测试
契约测试Schema
28
混沌工程测试
网络分区测试 · Leader选举测试 · 磁盘IO延迟注入测试
混沌工程测试网络分区测试
29
CI/CD集成测试流水线
GitLab CI/GitHub A… · 并行测试策略 · 测试报告生成
CI/CD集成测试流水线
30
综合实战案例
电商订单系统端到端集成测试 · 状态回溯与版本适配全流程演练
综合实战案例电商订单系统端到…