SuperAPI AI 工具集

kafka-topic-audit

智能体与模型

查看项目

更新于 10-15 23:58

技能介绍

用途:对 Kafka 集群中所有主题的配置进行生产最佳实践审计。资料指出,主题配置错误是 Kafka 数据丢失的首要原因,工程师创建主题后常忘记调优。

主要能力:通过 Lenses MCP 工具完成环境健康检查、拉取全部主题及配置、逐项审计配置、检查元数据完整性、检测无消费者组件的孤立主题、执行同域一致性检查,并生成报告。审计规则包括:复制因子 RF=1 为严重、RF=2 在生产为警告;保留策略无上限增长、过短或过长;分区数单分区瓶颈或过多;压缩设置中无键 compact 或状态主题用 delete;命名须符合 {domain}.{entity}.{event} 模式。元数据检查涵盖缺少描述、标签、键或值 schema 的主题。

使用方式:目标环境通过参数传入。工作流为:用 check_environment_health 获取环境概览;用 list_topics 一次拉取所有主题及配置,需要时用 get_topic、get_topic_broker_configs、get_topic_partitions 深入查看;按 references/audit-rules.md 阈值审计;用 list_topic_metadata 检查元数据,用 list_datasets 过滤发现异常;用 list_consumer_groups_by_topic 检测孤立主题;执行一致性检查后输出报告。报告按 Critical、Warning、Suggestion 分级,并附当前值与建议值。若环境不健康或不可达,应先停止并报告连接问题;返回零主题时报告并停止。

适用场景:例行周期审计、上线前生产就绪检查、针对单个主题的定向排查。

限制:依赖 Lenses MCP 服务器与 Lenses agent 在线且环境名正确;需要相应读取权限;Schema Registry 未配置时元数据为空应作为发现项而非错误;资料未提供具体安装命令、费用或价格信息。