An MCP server for Kafka cluster inspection, management, and monitoring. Provides tools for topic management, consumer lag tracking, cluster health diagnostics, and broker leadership analysis.
Scoring was not performed
Auto-discovers cluster signals + lag and returns OK/WARN/CRITICAL without external params. Built-in thresholds: offline_crit=1, urp_warn=1/urp_crit=5, lag_warn=10000/lag_crit=100000, single_broker_warn=True.
Return how many partitions each broker is the leader for.
Create a new topic.
Delete a topic.
Get detailed information about a specific topic.
Get comprehensive cluster health and metadata information.
Compute consumer lag for a specific consumer group and topic.
Returns all offline partitions (leader == -1).
| Scored | Grade | Overall | Spec posture | Rubric |
|---|---|---|---|---|
| 2026-09-22 | F | 8 | <=2025-11-25 | v2 |
| 2026-03-09 | F | 0 | - | v1 |
Get configuration for a specific topic.
Return topic names in the cluster. By default skips internal topics (e.g., __consumer_offsets).