用途：为生产 Kafka 提供可执行的 broker、producer、consumer 与 schema registry 护栏，避免破坏性 schema 变更、持久化配置不足和毒消息缺少隔离。适用于创建或修改 Kafka topic、producer、consumer，设置或变更 schema registry 兼容策略，设计毒消息 DLQ 路由，加固生产者持久化（acks、retries、幂等），以及审查消费延迟、重放与故障转移行为。可与 streaming-and-messaging-systems 搭配做事件设计，与 avro-protobuf-json-schema-registry 搭配处理 registry subject 与兼容性 CI。
主要能力与要求：变更前先定义生产契约，记录 topic key 策略与分区数依据、保留/压缩/重放策略、schema 格式与 registry subject 命名、消费组与下游 sink、投递语义目标。生产者默认要求 acks=all（或 acks=-1）、需要顺序与去重时 enable.idempotence=true、有界重试且 delivery.timeout.ms 对齐 SLA、严格顺序时 max.in.flight.requests.per.connection=1，非开发集群需记录 TLS/SASL 配置。schema 变更前按 subject 设置兼容策略（BACKWARD、FORWARD 或 FULL，生产禁用 NONE），在 CI 中对照已注册 schema 做兼容性检查，记录 producer-then-consumer 或 consumer-then-producer 的发布顺序，无迁移计划不得删除、重命名字段或改类型。每个解析外部负载的生产消费者必须定义 DLQ topic 或 sink（含保留与访问控制）、分类规则（反序列化失败、schema 不匹配、业务规则违规）、DLQ 速率超阈值告警路由、带去重键的重放流程，且不得静默丢弃无法解析的记录。还需规划消费组延迟告警与责任人、受限的 offset 重置策略、不绕过 DLQ 分类的重放手册、高吞吐 topic 的磁盘与保留监控。诊断实时延迟时可加载 MCP 可观测性，用 mcp-data-observability-integration 配合 mcp/kafka.mcp.json 查看消费组延迟与 topic 元数据。
限制：资料未提供具体安装命令、价格、平台支持或效果数据；该技能为规范与检查清单性质，需结合具体环境落地。