用途:审查 Kafka 生产者与消费者配置,在实时集群与代码库两侧发现性能反模式。参数 $ARGUMENTS 指定目标环境与路径,未指定路径时默认扫描 src/。
主要能力:通过 Lenses MCP 检查 topic 级配置(min.insync.replicas、compression.type、max.message.bytes)、broker 级配置(message.max.bytes、replica.fetch.max.bytes、num.io.threads)、分区分布(检测数据倾斜)及消息吞吐指标;在代码库中搜索生产者/消费者配置属性及同步发送、缺失回调、缺失优雅关闭等反模式;将代码配置与推荐值对照,并交叉比对集群与代码配置,输出含当前值、推荐值与权衡说明的报告。
使用方式:按六步流程执行——检查实时集群配置、扫描代码库、审计生产者配置、审计消费者配置、交叉比对、生成报告。生产者重点检查 acks、batch.size、linger.ms、compression.type、enable.idempotence、retries;消费者重点检查 max.poll.records、max.poll.interval.ms、auto.offset.reset、enable.auto.commit、fetch.min.bytes。
限制:若 MCP 调用失败,仅做代码库分析并注明;若代码库使用框架封装隐藏原始属性,需搜索框架特定配置模式并建议人工审查;低吞吐 topic 可能无法判定分区倾斜;未提供具体安装命令或价格信息。