SuperAPI AI 工具集

kafka-connector-review

智能体与模型

查看项目

更新于 10-15 23:58

技能介绍

用途:审查 Kafka Connect 连接器配置,发现常见错误配置。连接器以 JSON/YAML 定义,与语言无关。目标环境通过 $ARGUMENTS 指定。

主要能力:

  1. 列出所有连接器及其状态与任务状态,立即标记 FAILED 状态的连接器或任务、无理由 PAUSED 的连接器。
  2. 获取每个连接器的完整配置 YAML。
  3. 用插件 schema 校验配置,捕获缺失必填字段、无效值和类型不匹配。
  4. 审计常见错误配置:错误处理(如 errors.tolerance=all 但缺少 errors.deadletterqueue.topic.name 会静默丢消息)、转换器不匹配、SMT 链过长、tasks.max=1 影响并行度、缺少重试与超时、命名不规范等。
  5. 输出分级报告,含当前值与建议值。

使用方式:按五步工作流操作——列出连接器、检查配置、校验配置、审计错误配置、生成报告。主要调用 Lenses MCP 工具:list_kafka_connectors、get_kafka_connector_target_definition、validate_connector_configuration,也可用 get_deployment_targets 查看可用 Connect 集群。

适用场景:例行审查所有连接器、排查失败连接器、对单个连接器做深入审查。

限制:若无连接器返回,说明未配置 Connect 集群,应停止并报告;校验报未知插件属于部署问题而非配置问题;RUNNING 但任务 FAILED 需逐个检查任务状态,常见原因为认证失败、网络问题或 schema 不匹配。