kafka-mcp-server
If you are the rightful owner of kafka-mcp-server and would like to certify it and/or have it hosted online, please leave a comment on the right or send an email to henry@mcphub.com.
A Model Context Protocol (MCP) server for Apache Kafka implemented in Go, leveraging franz-go and mcp-go.
The Kafka MCP Server bridges the gap between LLM models and Apache Kafka, allowing them to produce and consume messages from topics, list, describe, and manage topics, monitor and manage consumer groups, assess cluster health and configuration, and execute standard Kafka operations all through the standardized Model Context Protocol (MCP).
Features
- Kafka Integration: Implementation of common Kafka operations via MCP
- Security: Support for SASL (PLAIN, SCRAM-SHA-256, SCRAM-SHA-512) and TLS authentication
- Error Handling: Error handling with meaningful feedback
- Configuration Options: Customizable for different environments
- Compatibility: Works with MCP-compatible LLM models
Tools
produce_message
Produces a single message to a Kafka topic with optional key.
consume_messages
Consumes a batch of messages from one or more Kafka topics.
list_brokers
Lists the configured Kafka broker addresses the server is connected to.
describe_topic
Provides detailed metadata for a specific Kafka topic.
list_consumer_groups
Enumerates active consumer groups known by the Kafka cluster.