lag

DE//AGENT currently lists 9 resources under lag: 4 tutorials, 1 skill, 1 mcp server. Everything below is derived from the live registry — counts, capabilities, verification state and security posture come from the curated records, never from marketing copy.

Also present: 1 plugin, 1 agent, 1 runbook.

Documented learning objectives across these resources:

• Configure the Kafka MCP server against a broker list — via Inspect Kafka topics and groups with the Kafka MCP server
• Inventory topics and read group lag with the four tools — via Inspect Kafka topics and groups with the Kafka MCP server
• Sample messages without leaking production PII — via Inspect Kafka topics and groups with the Kafka MCP server
• Feed an incident agent the inputs it needs — group describe, offsets, logs — via Troubleshoot a lagging group with the Kafka Troubleshooter
• Follow a diagnosis, evidence, fix, prevention loop — via Troubleshoot a lagging group with the Kafka Troubleshooter
• Keep destructive shortcuts like offset resets off the table — via Troubleshoot a lagging group with the Kafka Troubleshooter
• Inventory topics with /topic-info before touching lag — via Debug a Kafka stream with the Kafka Console plugin
• Triage per-partition lag and rebalance detection with /lag-triage — via Debug a Kafka stream with the Kafka Console plugin

4 more objectives live on the individual resource pages.

These resources map to stage: Streaming (9). Follow the four-phase roadmap to place this topic inside a progression instead of learning it in isolation.

Every entry, its shape and its trust state — sorted by the registry's composite score. This table is the honest version of a marketing comparison: no sponsored placements, no unverifiable claims.

How scores are computed: source quality score.

Highest composite score first:

1. Kafka MCP Server score 37.6 — advanced
2. Inspect Kafka topics and groups with the Kafka MCP server score 34.15 — beginner
3. Troubleshoot a lagging group with the Kafka Troubleshooter score 34.15 — beginner

Scores rank provenance, completeness and trust — read how verification works before adopting anything.

Start here if you're new: Inspect Kafka topics and groups with the Kafka MCP server, Troubleshoot a lagging group with the Kafka Troubleshooter.

Reach for these with production experience: Kafka MCP Server, Kafka Consumer Lag Triage, Kafka Troubleshooter.

Security-flagged entries: Kafka MCP Server (2 flags), Kafka Consumer Lag Triage (3 flags), Kafka Troubleshooter (2 flags), Kafka consumer lagging (3 flags), Kafka Console (3 flags). Flags mean the record declares capabilities like credential use or write access — read the security posture on each page before connecting.

• Kafka MCP Server — Community server for Apache Kafka that lists topics, reads consumer-group lag, and samples messages, for stream debugging from an agent. details
• Inspect Kafka topics and groups with the Kafka MCP server — Connect an agent to a Kafka cluster through the Kafka MCP server and work through its four tools: list_topics for inventory, describe_topic for a single topic, describe_consumer_gr… details
• Troubleshoot a lagging group with the Kafka Troubleshooter — Hand the Kafka Troubleshooter agent the consumer-group describe output, per-partition offsets, and consumer logs, then follow its four-step workflow from lag trend to the least des… details
• Debug a Kafka stream with the Kafka Console plugin — Drive the Kafka Console plugin's three commands across a lag incident: /topic-info for inventory, /lag-triage for per-partition lag and rebalance detection, and /sample-topic for a… details

Real install commands from the registry — read the source before running any of them:

kafka-mcp-server

Kafka MCP Server — review first

npx de-agent-platform add kafka-consumer-lag-triage

Kafka Consumer Lag Triage — review first

amp plugin add de-agent/kafka-console

Kafka Console — review first

Adjacent topics: streaming (5 shared), tutorial (4 shared), incidents (4 shared), mcp (2 shared), plugin (2 shared), agent (2 shared).

Study path: the roadmap places this topic in a progression · the scoring model explains the numbers · the trust rule catalog shows every security check these entries passed through.