Kafka MCP

Kafka MCP

Visão Geral

O Kafka MCP Server oferece uma maneira eficiente de converter prompts em ações no ecossistema Kafka. É uma interface de linguagem natural projetada para aplicações agênticas gerenciarem operações Kafka de forma eficiente e se integrarem perfeitamente com clientes MCP, permitindo que fluxos de trabalho orientados por IA interajam com processos no Kafka. Usando este MCP Server, você pode fazer perguntas como:

1. Publicar mensagem 'estou usando o servidor kafka' no tópico 'test-kafka'
2. Consumir a mensagem do tópico 'test-kafka'
3. Listar todos os tópicos do ambiente kafka

Recursos

• Consultas em Linguagem Natural: Permite que agentes de IA consultem e atualizem o Redis usando linguagem natural.
• Integração MCP Perfeita: Funciona com qualquer cliente MCP para comunicação fluida.
• Suporte Completo ao Kafka: Lida com produtor, consumidor, tópicos, broker, partições e offsets.
• Escalável e Leve: Projetado para operações de dados de alto desempenho.

Ferramentas

Este MCP Server oferece várias ferramentas para Kafka:

As ferramentas consumer e producer permitem consumir e publicar mensagens em tópicos.

As ferramentas topic permitem list, create, delete e describe tópicos no Kafka.

broker permite obter informações do broker.

As ferramentas partition permitem obter partições e offsets de partições.

As ferramentas group_offset permitem obter e redefinir offsets no Kafka.

Configurações

Defina o seguinte no arquivo .env ou exporte manualmente

BOOTSTRAP_SERVERS=your_kafka_server
MCP_TRANSPORT=stdio

Desenvolvimento Local

Crie um ambiente 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

Instale as Dependências

# Using pip
pip install -r requirements.txt

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

Defina as Configurações no terminal/ambiente

BOOTSTRAP_SERVERS=<your_kafka_url>
MCP_TRANSPORT=stdio

Execute a aplicação

python3 src/main.py

# OR

uv run python3 src/main.py

Para interagir com o servidor,

Adicione a seguinte configuração ao arquivo config.json do seu servidor MCPO (por exemplo, no 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"
      }
    }
  }
}

Exemplos de prompts

• Liste todos os tópicos no cluster kafka
• Crie o tópico 'my-kafka' no cluster kafka
• Publique uma mensagem 'olá do mcp' no tópico 'my-kafka' no cluster
• Consuma 2 mensagens do tópico 'my-kafka' no cluster kafka
• Descreva o tópico 'my-kafka'