kafka-mcp-server
Verified Safeby tuannvm
Overview
Enables LLM models and AI applications to interact with Apache Kafka for producing/consuming messages, managing topics, monitoring consumer groups, and assessing cluster health via the Model Context Protocol (MCP).
Installation
go run cmd/main.goEnvironment Variables
- KAFKA_BROKERS
- KAFKA_SASL_MECHANISM
- KAFKA_SASL_USER
- KAFKA_SASL_PASSWORD
- KAFKA_TLS_ENABLE
- OAUTH_ENABLED
- OAUTH_MODE
- OAUTH_PROVIDER
- OAUTH_SERVER_URL
- OIDC_ISSUER
- OIDC_CLIENT_ID
- OIDC_CLIENT_SECRET
- OIDC_AUDIENCE
- OAUTH_REDIRECT_URIS
- JWT_SECRET
- KAFKA_CLIENT_ID
- MCP_TRANSPORT
- KAFKA_TLS_INSECURE_SKIP_VERIFY
- MCP_HTTP_PORT
Security Notes
The server leverages environment variables for all sensitive configurations (Kafka credentials, OAuth secrets), eliminating hardcoded secrets. It supports robust authentication mechanisms for Kafka (SASL, TLS) and the MCP server (OAuth 2.1 via HTTP transport). Input validation is present for tool arguments. However, using `KAFKA_TLS_INSECURE_SKIP_VERIFY=true` in production poses a significant man-in-the-middle risk, and the documentation explicitly warns against it. Overall, a secure setup is achievable but requires careful configuration by the user.
Similar Servers
slack-mcp-server
Provides a Model Context Protocol (MCP) server for integrating Slack workspace data and communication capabilities with AI models and agents.
mcp-k8s-go
This MCP server enables interaction with Kubernetes clusters to list, get, apply, and execute commands on various resources through a conversational interface.
mkp
MKP is a Model Context Protocol (MCP) server for Kubernetes, enabling LLM-powered applications to interact with Kubernetes clusters by providing tools for resource listing, getting, applying, deleting, and executing commands.
kafka-schema-reg-mcp
A comprehensive Model Context Protocol (MCP) server that provides Claude Desktop and other MCP clients with tools for Kafka Schema Registry operations, including schema management, migration, and export.