用途：该技能用于分析 Kafka 各消费者组的 lag，是故障排查时常用手段，帮助定位消费落后的原因并给出分组处置建议。
主要能力：调用 Lenses MCP 工具获取全部消费者组的状态（Stable、Rebalancing、Empty、Dead）、每个 topic-partition 的 lag、活跃成员数与协调者信息；按主题分析时用 list_consumer_groups_by_topic。按严重程度分为 Critical（Dead/Empty 但仍有已提交 offset、lag 持续增长）、Warning（再平衡中、分区分配不均、无已提交 offset）、Suggestion（成员数远多于分区数、消费的主题近期无消息）三级。
诊断逻辑：lag 增长但生产者速率稳定，多为消费吞吐瓶颈；lag 尖峰伴随再平衡，说明消费暂停；单分区 lag 通常为热分区或 key 倾斜；全分区均匀 lag 为整体消费变慢；零 lag 但组为空说明消费者崩溃或已停用。对应建议包括扩容消费者、调整 max.poll.records、改用 cooperative sticky assignor、调整 session.timeout.ms、检查分区策略等。可用 execute_sql 抽样消息（如 SELECT * FROM {topic} LIMIT 5）并结合 get_dataset_message_metrics 确认数据流。
使用方式：将目标环境作为参数（$ARGUMENTS）传入，按四步流程执行——获取消费者组、识别问题组、诊断根因、生成报告；报告按 Critical/Warning/Suggestion 表格列出组、主题、总 lag、状态、诊断与处置。
限制：依赖 Lenses MCP 服务器及其权限，若无消费者组或权限受限则无法分析；消费者停止后 offset 可能过期导致 lag 数值不准，需与分区末端 offset 比对；资料未说明具体的部署与计费方式。