{"id":"a3a2311d-aee2-4e78-bdc6-80c5a787eb0d","shortId":"TBDAcv","kind":"skill","title":"Apache Kafka Consumer Lag Runbook","tagline":"Diagnoses Kafka consumer group lag using the Kafka AdminClient API and JMX metrics exposed via the Confluent Metrics API. Identifies slow consumers, topic partition hotspots, and broker rebalance storms that contribute to lag growth. Provides a step-by-step runbook to tune fetch.","description":"# Apache Kafka Consumer Lag Runbook\n\nDiagnoses Kafka consumer group lag using the Kafka AdminClient API and JMX metrics exposed via the Confluent Metrics API. Identifies slow consumers, topic partition hotspots, and broker rebalance storms that contribute to lag growth. Provides a step-by-step runbook to tune fetch.min.bytes, max.poll.records, and partition count.\n\n## Prerequisites\n\nJava\n\n## Installation\n\nUse the upstream install or setup path that matches your environment:\n- docker run -p 9092:9092 apache/kafka:latest\n\nRequirements and caveats from upstream:\n- Using docker image:\n- See [docker/README.md](docker/README.md) for detailed information.\n\nBasic usage or getting-started notes:\n- ### Build a JAR and run it\n- ### Run unit/integration tests\n- ./gradlew test -Pkafka.test.run.flaky=true # runs tests that are marked as flaky\n\n- Source: https://github.com/apache/kafka\n- Extracted from upstream docs: https://raw.githubusercontent.com/apache/kafka/HEAD/README.md\n\n## Documentation\n\n- https://kafka.apache.org/documentation/\n\n## Source\n\n- [Agent Skill Exchange](https://agentskillexchange.com/skills/apache-kafka-consumer-lag-runbook/)","tags":["apache","kafka","consumer","lag","runbook","skills","agentskillexchange","agent-skills","ai-agents","ai-tools","awesome-list","claude-code"],"capabilities":["skill","source-agentskillexchange","skill-apache-kafka-consumer-lag-runbook","topic-agent-skills","topic-ai-agents","topic-ai-tools","topic-awesome-list","topic-claude-code","topic-codex","topic-cursor","topic-llm","topic-mcp","topic-npx-skills","topic-openclaw","topic-skills-catalog"],"categories":["skills"],"synonyms":[],"warnings":[],"endpointUrl":"https://skills.sh/agentskillexchange/skills/apache-kafka-consumer-lag-runbook","protocol":"skill","transport":"skills-sh","auth":{"type":"none","details":{"cli":"npx skills add agentskillexchange/skills","source_repo":"https://github.com/agentskillexchange/skills","install_from":"skills.sh"}},"qualityScore":"0.454","qualityRationale":"deterministic score 0.45 from registry signals: · indexed on github topic:agent-skills · 8 github stars · SKILL.md body (1,149 chars)","verified":false,"liveness":"unknown","lastLivenessCheck":null,"agentReviews":{"count":0,"score_avg":null,"cost_usd_avg":null,"success_rate":null,"latency_p50_ms":null,"narrative_summary":null,"summary_updated_at":null},"enrichmentModel":"deterministic:skill-github:v1","enrichmentVersion":1,"enrichedAt":"2026-05-18T19:09:22.464Z","embedding":null,"createdAt":"2026-05-18T13:15:04.827Z","updatedAt":"2026-05-18T19:09:22.464Z","lastSeenAt":"2026-05-18T19:09:22.464Z","tsv":"'/apache/kafka':168 '/apache/kafka/head/readme.md':175 '/documentation/':179 '/gradlew':154 '/skills/apache-kafka-consumer-lag-runbook/)':186 '9092':120,121 'admincli':14,63 'agent':181 'agentskillexchange.com':185 'agentskillexchange.com/skills/apache-kafka-consumer-lag-runbook/)':184 'apach':1,50 'apache/kafka':122 'api':15,24,64,73 'basic':138 'broker':32,81 'build':145 'caveat':126 'confluent':22,71 'consum':3,8,27,52,57,76 'contribut':36,85 'count':102 'detail':136 'diagnos':6,55 'doc':172 'docker':117,130 'docker/readme.md':133,134 'document':176 'environ':116 'exchang':183 'expos':19,68 'extract':169 'fetch':49 'fetch.min.bytes':98 'flaki':164 'get':142 'getting-start':141 'github.com':167 'github.com/apache/kafka':166 'group':9,58 'growth':39,88 'hotspot':30,79 'identifi':25,74 'imag':131 'inform':137 'instal':105,109 'jar':147 'java':104 'jmx':17,66 'kafka':2,7,13,51,56,62 'kafka.apache.org':178 'kafka.apache.org/documentation/':177 'lag':4,10,38,53,59,87 'latest':123 'mark':162 'match':114 'max.poll.records':99 'metric':18,23,67,72 'note':144 'p':119 'partit':29,78,101 'path':112 'pkafka.test.run.flaky':156 'prerequisit':103 'provid':40,89 'raw.githubusercontent.com':174 'raw.githubusercontent.com/apache/kafka/head/readme.md':173 'rebal':33,82 'requir':124 'run':118,149,151,158 'runbook':5,46,54,95 'see':132 'setup':111 'skill':182 'skill-apache-kafka-consumer-lag-runbook' 'slow':26,75 'sourc':165,180 'source-agentskillexchange' 'start':143 'step':43,45,92,94 'step-by-step':42,91 'storm':34,83 'test':153,155,159 'topic':28,77 'topic-agent-skills' 'topic-ai-agents' 'topic-ai-tools' 'topic-awesome-list' 'topic-claude-code' 'topic-codex' 'topic-cursor' 'topic-llm' 'topic-mcp' 'topic-npx-skills' 'topic-openclaw' 'topic-skills-catalog' 'true':157 'tune':48,97 'unit/integration':152 'upstream':108,128,171 'usag':139 'use':11,60,106,129 'via':20,69","prices":[{"id":"5328f6b9-df1f-4acb-9e2d-fab1e3fb2e55","listingId":"a3a2311d-aee2-4e78-bdc6-80c5a787eb0d","amountUsd":"0","unit":"free","nativeCurrency":null,"nativeAmount":null,"chain":null,"payTo":null,"paymentMethod":"skill-free","isPrimary":true,"details":{"org":"agentskillexchange","category":"skills","install_from":"skills.sh"},"createdAt":"2026-05-18T13:15:04.827Z"}],"sources":[{"listingId":"a3a2311d-aee2-4e78-bdc6-80c5a787eb0d","source":"github","sourceId":"agentskillexchange/skills/apache-kafka-consumer-lag-runbook","sourceUrl":"https://github.com/agentskillexchange/skills/tree/main/skills/apache-kafka-consumer-lag-runbook","isPrimary":false,"firstSeenAt":"2026-05-18T13:15:04.827Z","lastSeenAt":"2026-05-18T19:09:22.464Z"}],"details":{"listingId":"a3a2311d-aee2-4e78-bdc6-80c5a787eb0d","quickStartSnippet":null,"exampleRequest":null,"exampleResponse":null,"schema":null,"openapiUrl":null,"agentsTxtUrl":null,"citations":[],"useCases":[],"bestFor":[],"notFor":[],"kindDetails":{"org":"agentskillexchange","slug":"apache-kafka-consumer-lag-runbook","github":{"repo":"agentskillexchange/skills","stars":8,"topics":["agent-skills","ai-agents","ai-tools","awesome-list","claude-code","codex","cursor","llm","mcp","npx-skills","openclaw","skills-catalog"],"license":"mit","html_url":"https://github.com/agentskillexchange/skills","pushed_at":"2026-05-18T19:02:17Z","description":"The open catalog of AI agent skills — 2,000+ security-scanned skills for Claude Code, Cursor, Codex, and more.","skill_md_sha":"0f8ed681b2fec55a5a2fe32452a1b149438ff825","skill_md_path":"skills/apache-kafka-consumer-lag-runbook/SKILL.md","default_branch":"main","skill_tree_url":"https://github.com/agentskillexchange/skills/tree/main/skills/apache-kafka-consumer-lag-runbook"},"layout":"multi","source":"github","category":"skills","frontmatter":{"name":"Apache Kafka Consumer Lag Runbook","description":"Diagnoses Kafka consumer group lag using the Kafka AdminClient API and JMX metrics exposed via the Confluent Metrics API. Identifies slow consumers, topic partition hotspots, and broker rebalance storms that contribute to lag growth. Provides a step-by-step runbook to tune fetch.min.bytes, max.poll.records, and partition count."},"skills_sh_url":"https://skills.sh/agentskillexchange/skills/apache-kafka-consumer-lag-runbook"},"updatedAt":"2026-05-18T19:09:22.464Z"}}