Kafka MCP

Kafka MCP

Resumen

El servidor Kafka MCP ofrece una forma eficiente de convertir indicaciones en acciones dentro del ecosistema Kafka. Es una interfaz de lenguaje natural diseñada para aplicaciones agénticas que permite gestionar operaciones de Kafka de manera eficiente e integrarse sin problemas con clientes MCP, habilitando flujos de trabajo impulsados por IA para interactuar con procesos en Kafka. Con este servidor MCP, puedes hacer preguntas como:

1. Publicar el mensaje 'estoy usando el servidor kafka' en el tema 'test-kafka'
2. Consumir el mensaje del tema 'test-kafka'
3. Listar todos los temas del entorno kafka

Características

• Consultas en lenguaje natural: permite a los agentes de IA consultar y actualizar Redis usando lenguaje natural.
• Integración MCP sin fisuras: funciona con cualquier cliente MCP para una comunicación fluida.
• Soporte completo de Kafka: maneja productor, consumidor, temas, brokers, particiones y offsets.
• Escalable y ligero: diseñado para operaciones de datos de alto rendimiento.

Herramientas

Este servidor MCP ofrece varias herramientas para Kafka:

Las herramientas consumer y producer permiten consumir y publicar mensajes en temas.

Las herramientas topic permiten list, create, delete y describe temas en Kafka.

broker permite obtener información del broker.

Las herramientas partition permiten obtener particiones y offsets de particiones.

Las herramientas group_offset permiten obtener y restablecer offsets en Kafka.

Configuraciones

Establece lo siguiente en el archivo .env o expórtalo manualmente

BOOTSTRAP_SERVERS=your_kafka_server
MCP_TRANSPORT=stdio

Desarrollo local

Crea un entorno virtual

# Using venv (built-in)
python3 -m venv .venv

# Activate the virtual environment
# On Windows
.venv\Scripts\activate

# On macOS/Linux
source .venv/bin/activate

Instala las dependencias

# Using pip
pip install -r requirements.txt

# Or using uv (faster)
uv pip install -r requirements.txt

Establece las configuraciones en la terminal/entorno

BOOTSTRAP_SERVERS=<your_kafka_url>
MCP_TRANSPORT=stdio

Ejecuta la aplicación

python3 src/main.py

# OR

uv run python3 src/main.py

Para interactuar con el servidor,

Agrega la siguiente configuración al archivo config.json de tu servidor MCPO (por ejemplo, en Claude Desktop):

{
  "mcpServers": {
    "kafka-mcp": {
      "command": "python3",
      "args": ["/Users/I528600/Desktop/mcp/kafka-mcp/src/main.py"],
      "env": {
        "BOOTSTRAP_SERVERS": "localhost:9092",
        "MCP_TRANSPORT": "stdio"
      }
    }
  }
}

Ejemplos de indicaciones

• Listar todos los temas en el clúster de kafka
• Crear el tema 'my-kafka' en el clúster de kafka
• Publicar un mensaje 'hola desde mcp' en el tema 'my-kafka' del clúster
• Consumir 2 mensajes del tema 'my-kafka' en el clúster de kafka
• Describir el tema 'my-kafka'