用途:在 Kafka 主题 schema 变更合并前或故障排查时,评审其兼容性与演化实践。一次破坏性 schema 变更可能导致该主题的所有消费者不可用。目标环境由 $ARGUMENTS 指定。
主要能力:从在线集群获取已注册 schema;扫描代码库中的 schema 定义文件;按兼容性规则检测破坏性变更(backward、forward、full 依主题配置的兼容级别而定);检查 schema 质量;检测仓库与集群之间的 schema 漂移;生成含迁移指导的报告。
使用方式:按六步工作流推进——获取已注册 schema、扫描代码库、检测破坏性变更、检查 schema 质量、检查 schema 漂移、生成报告。常用 Lenses MCP 工具:list_topic_metadata(获取主题上注册的键和值 schema)、get_topic_metadata(获取特定主题当前 schema)、get_dataset(获取数据集字段、策略与治理元数据)、list_datasets 带 schema_format 过滤(查找使用 AVRO、JSON 或 PROTOBUF 的主题)、execute_sql(抽样实时数据核对 schema)。评审 PR 时可用 git diff 找出近期变更的 schema 文件;具体文件类型与搜索模式参见 references/compatibility-rules.md。
适用场景:合并前 schema 评审、staging 环境全量 schema 审计、消费者反序列化失败诊断。输出格式按破坏性变更、兼容性警告、schema 质量、schema 漂移、汇总分段,破坏性变更需给出受影响主题与迁移建议。
限制与注意:若集群未注册 schema,视为治理缺口而非错误,仅做代码库分析;漂移若为有意变更,建议以集群为唯一事实来源同步仓库;无法用 execute_sql 抽样时(主题为空、权限受限或格式不支持)在报告中注明,并回退使用 get_topic_metadata。资料未提供安装命令、价格与平台支持信息。