sk Skill · lensesio
kafka-consumer-lag
Analyse Kafka consumer group lag using the Lenses MCP server. Diagnoses lag causes (throughput bottlenecks, rebalancing, partition skew, stalled consumers) and suggests remediation. Use when user says "check consumer lag", "why are consumers slow", "lag report" or asks about consumer group health or offset progress. Do NOT use for resetting offsets or managing consumer groups.
Open on skills.sh ↗read 2026-09-15
- installs 8w
- 0
- 30-day movement
- starts with the next reading
- Related entries
- 1
- Connections
- 9
sqlmcp-enhancementPythondiagnosticsmonitoringlagconsumerskafka
- Host repository
- lensesio/agentic-engineering-for-apache-kafka
- Category
- mcp-enhancement
- Version
- 1.0.0
- Allowed tools
- Read, Grep, Glob, Bash, mcp__Lenses__list_consumer_groups, mcp__Lenses__list_consumer_groups_by_topic, mcp__Lenses__get_topic_partitions, mcp__Lenses__get_dataset_message_metrics, mcp__Lenses__execute_sql
- Compatible with
- get_consumer_group, etc.) will also work, without an MCP server, the skill falls back to codebase-only inspection and skips live-cluster checks.
- Licence
- MIT
- Host stars
- 57
- Host language
- Python