VIP20

本课程属于：049-API设计治理Kafka堆积诊断 Web后端与企业应用开发 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

← 返回所属目录咨询 / 购买

KafkaAPI Kafka诊断契约校验

共计 30 章节

点击此处阅读海量试读课程：100+行业、1000+细分领域

Kafka基础回顾

Kafka核心概念（Topic · Partition · Broker

Kafka基础回顾

Kafka API概览

Producer API · Consumer API · AdminClient API

Producer API详解

同步发送与异步发送 · 回调机制 · 分区策略

Producer配置调优

acks · retries · batch.size

Producer配置调优

Consumer API详解

订阅模式（subscribe/ass… · 位移提交（自动/手动） · 再均衡监听器

Consumer配置调优

session.timeout.ms · max.poll.interval.… · max.poll.records

Consumer配置调优

AdminClient API

创建/删除Topic · 查看集群元数据 · 修改配置

Streams API入门

流处理拓扑 · KStream与KTable · 状态存储

Connect API入门

Source Connector与S… · 单机模式与分布式模式

API契约校验概念

什么是API契约 · 契约校验的目的（兼容性 · 正确性

API契约校验概念

Kafka API契约定义

使用OpenAPI/Swagger定… · 使用AsyncAPI定义异步消息契约

Schema Registry与契约

Avro/Protobuf/JSON… · 版本管理 · 兼容性检查（BACKWARD/FOR…

Producer API契约校验

校验消息Key/Value的Sche… · 校验必填字段 · 校验分区路由逻辑

Consumer API契约校验

校验订阅Topic是否存在 · 校验位移提交格式 · 校验反序列化兼容性

AdminClient API契约校验

校验Topic配置参数合法性 · 校验ACL权限 · 校验集群资源限制

Streams API契约校验

校验拓扑节点连接 · 校验状态存储Schema · 校验窗口大小与时间戳语义

Connect API契约校验

校验Connector配置完整性 · 校验Converter配置 · 校验Task状态

诊断工具介绍

kafka-consumer-gro… · kafka-topics.sh · kafka-configs.sh

诊断工具介绍kafka-consum…

诊断指标与监控

JMX指标（请求速率 · 延迟 · 错误率）

诊断指标监控

常见Producer诊断

消息发送超时 · Leader选举期间异常 · 批次过大导致OOM

常见Consumer诊断

消费滞后（Lag）过大 · 再均衡风暴 · 位移提交失败

常见Broker诊断

磁盘空间不足 · 网络吞吐瓶颈 · Controller选举频繁

契约校验自动化

基于CI/CD的契约测试流水线 · 使用Pact框架进行消费者驱动契约测…

契约校验自动化CI/CD

契约校验工具选型

Spring Cloud Contr… · Pact · AsyncAPI CLI

契约校验工具选型Spring

实战案例一

构建一个带契约校验的订单事件Prod… · 使用Avro Schema并验证兼容…

实战案例一Prod

实战案例二

构建一个带契约校验的支付结果Cons… · 使用Protobuf并验证反序列化

实战案例二Cons

实战案例三

使用AdminClient自动化校验…

实战案例三AdminClient

实战案例四

为Streams应用编写拓扑契约测试 · 确保状态存储Schema不破坏下游

实战案例四Streams

实战案例五

为Kafka Connect编写Co… · 防止配置漂移

实战案例五Kafka

课程总结与最佳实践

API契约校验的收益 · 常见陷阱 · 未来趋势（KIP-932等）

课程总结最佳实践