MCP Kafka
by williajm
Server Configuration
Describes the environment variables required to run the server.
| Name | Required | Description | Default |
|---|---|---|---|
| KAFKA_TIMEOUT | No | Operation timeout in seconds | 30 |
| KAFKA_CLIENT_ID | No | Client identifier | mcp-kafka |
| KAFKA_SASL_PASSWORD | No | SASL password | |
| KAFKA_SASL_USERNAME | No | SASL username | |
| KAFKA_SASL_MECHANISM | No | SASL mechanism (PLAIN, SCRAM-SHA-256, SCRAM-SHA-512, GSSAPI) | |
| KAFKA_SSL_CA_LOCATION | No | CA certificate path | |
| SECURITY_OAUTH_ISSUER | No | OAuth issuer URL (e.g., https://auth.example.com) | |
| KAFKA_SSL_KEY_LOCATION | No | Client key path | |
| KAFKA_SSL_KEY_PASSWORD | No | Client key password | |
| SAFETY_TOPIC_BLOCKLIST | No | Comma-separated blocked topic patterns | |
| SECURITY_OAUTH_ENABLED | No | Enable OAuth/OIDC authentication | false |
| KAFKA_BOOTSTRAP_SERVERS | No | Kafka broker addresses | localhost:9092 |
| KAFKA_SECURITY_PROTOCOL | No | Security protocol (PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL) | PLAINTEXT |
| SAFETY_MAX_MESSAGE_SIZE | No | Max message size in bytes (1MB) | 1048576 |
| SECURITY_AUDIT_LOG_FILE | No | Audit log file path | mcp_audit.log |
| SECURITY_OAUTH_AUDIENCE | No | Expected JWT audience claim | |
| SECURITY_OAUTH_JWKS_URL | No | JWKS endpoint URL (auto-derived from issuer if not set) | |
| SECURITY_RATE_LIMIT_RPM | No | Max requests per minute | 60 |
| KAFKA_SASL_KERBEROS_KEYTAB | No | Path to Kerberos keytab | |
| SECURITY_AUDIT_LOG_ENABLED | No | Enable audit logging | true |
| SAFETY_MAX_CONSUME_MESSAGES | No | Max messages per consume request | 100 |
| SECURITY_RATE_LIMIT_ENABLED | No | Enable rate limiting | true |
| KAFKA_SASL_KERBEROS_PRINCIPAL | No | Kerberos principal | |
| SAFETY_ALLOW_WRITE_OPERATIONS | No | Enable READ/WRITE tools | false |
| KAFKA_SSL_CERTIFICATE_LOCATION | No | Client certificate path | |
| KAFKA_SASL_KERBEROS_SERVICE_NAME | No | Kerberos service name | kafka |
Capabilities
Server capabilities have not been inspected yet.
Tools
Functions exposed to the LLM to take actions
| Name | Description |
|---|---|
No tools | |
Prompts
Interactive templates invoked by user choice
| Name | Description |
|---|---|
No prompts | |
Resources
Contextual data attached and managed by the client
| Name | Description |
|---|---|
No resources | |
Latest Blog Posts
MCP directory API
We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/williajm/mcp_kafka'
If you have feedback or need assistance with the MCP directory API, please join our Discord server