BigHugger
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.

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