An MCP server that enables AI assistants to safely interact with Apache Kafka clusters, providing tools for topic management, message operations, consumer groups, and cluster information.
| Tool name | Description | Destructive? |
|---|---|---|
| kafka_list_topics | ✓ no | |
| kafka_describe_topic | ✓ no | |
| kafka_list_consumer_groups | ✓ no | |
| kafka_describe_consumer_group | ✓ no | |
| kafka_get_consumer_lag | ✓ no |
| kafka_cluster_info | ✓ no | |
| kafka_list_brokers | ✓ no | |
| kafka_get_watermarks⚠ | ⚠ yes | |
| kafka_consume_messages | ✓ no | |
| kafka_create_topic | ✓ no | |
| kafka_produce_message | ✓ no | |
| kafka_reset_offsets | ✓ no |