mcp-kafka-client
Verified Safeby jesrzrz
Overview
Interact with Apache Kafka and Schema Registry for topic management, schema operations, and message handling within an MCP environment.
Installation
python -m kafka_mcp.serverEnvironment Variables
- KAFKA_BOOTSTRAP_SERVERS
- SCHEMA_REGISTRY_URL
- KAFKA_SECURITY_PROTOCOL
- KAFKA_SASL_MECHANISM
- KAFKA_SASL_USERNAME
- KAFKA_SASL_PASSWORD
- KAFKA_SSL_CA_LOCATION
- KAFKA_SSL_CERTIFICATE_LOCATION
- KAFKA_SSL_KEY_LOCATION
- KAFKA_SSL_KEY_PASSWORD
- SCHEMA_REGISTRY_BASIC_AUTH_USER_INFO
- AZURE_TENANT_ID
- AZURE_CLIENT_ID
- AZURE_CLIENT_SECRET
- AZURE_SCOPE
Security Notes
The server leverages established secure libraries (confluent-kafka, pydantic-settings) and extensively documents security best practices (e.g., storing credentials in .env, using SASL_SSL, not committing secrets). It performs SSL certificate validation. However, its security relies heavily on correct external configuration of Kafka, Schema Registry, and SSL certificates. Direct user input is processed within defined Avro schemas or JSON structures, mitigating typical injection risks, but no sandboxing is apparent.
Similar Servers
mongodb-mcp-server
Provides a robust AI agent interface for interacting with MongoDB databases and MongoDB Atlas cloud services, enabling tool-calling for data management, monitoring, and search operations.
kafka-mcp-server
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).
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.
jsonv-ts
Provides a type-safe JSON Schema builder and validator in TypeScript, with integrated Hono middleware for OpenAPI generation and request validation, and an MCP (Model Context Protocol) server/client for agent-based interactions.