Loading languages...
KA

kafka-mcp-server

@tuannvm36

A Model Context Protocol (MCP) server for Apache Kafka implemented in Go, leveraging franz-go and mcp-go.

kafka
messaging
event-streaming
go

# mcpServer Config

{
  "mcpServers": {
    "kafka": {
      "command": "kafka-mcp-server",
      "env": {
        "KAFKA_BROKERS": "localhost:9092",
        "KAFKA_CLIENT_ID": "kafka-mcp-server",
        "MCP_TRANSPORT": "stdio",
        "KAFKA_SASL_MECHANISM": "",
        "KAFKA_SASL_USER": "",
        "KAFKA_SASL_PASSWORD": "",
        "KAFKA_TLS_ENABLE": "false",
        "KAFKA_TLS_INSECURE_SKIP_VERIFY": "false"
      }
    }
  }
}

# stdio

kafka-mcp-server

# sseURL

http://localhost:9097/sse
Transport:
stdio
sse
भाषा:
Go
बनाया गया:4/18/2025
अद्यतन किया गया:11/1/2025