用途:审查 Kafka Connect 连接器配置,发现常见错误配置。连接器以 JSON/YAML 定义,与语言无关。目标环境通过 $ARGUMENTS 指定。
主要能力:
- 列出所有连接器及其状态与任务状态,立即标记 FAILED 状态的连接器或任务、无理由 PAUSED 的连接器。
- 获取每个连接器的完整配置 YAML。
- 用插件 schema 校验配置,捕获缺失必填字段、无效值和类型不匹配。
- 审计常见错误配置:错误处理(如 errors.tolerance=all 但缺少 errors.deadletterqueue.topic.name 会静默丢消息)、转换器不匹配、SMT 链过长、tasks.max=1 影响并行度、缺少重试与超时、命名不规范等。
- 输出分级报告,含当前值与建议值。
使用方式:按五步工作流操作——列出连接器、检查配置、校验配置、审计错误配置、生成报告。主要调用 Lenses MCP 工具:list_kafka_connectors、get_kafka_connector_target_definition、validate_connector_configuration,也可用 get_deployment_targets 查看可用 Connect 集群。
适用场景:例行审查所有连接器、排查失败连接器、对单个连接器做深入审查。
限制:若无连接器返回,说明未配置 Connect 集群,应停止并报告;校验报未知插件属于部署问题而非配置问题;RUNNING 但任务 FAILED 需逐个检查任务状态,常见原因为认证失败、网络问题或 schema 不匹配。