Back to directory
tuannvm/kafka-mcp-server

tuannvm/kafka-mcp-server

@tuannvm

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

kafkamcpgostreamingmessage-queueapache-kafkafranz-gomcp-gotool

Installation & Configuration

{
  "mcpServers": {
    "kafka": {
      "command": "kafka-mcp-server",
      "args": [],
      "env": {
        "KAFKA_BROKERS": "localhost:9092",
        "KAFKA_CLIENT_ID": "kafka-mcp-server",
        "MCP_TRANSPORT": "stdio"
      }
    }
  }
}

Information

Transport
stdiosse
Language
Go
Created
2026/6/13
Updated
2026/6/13