{"repo":"tuannvm/kafka-mcp-server","free":true,"listed":false,"github":"https://github.com/tuannvm/kafka-mcp-server","clone":"git clone https://github.com/tuannvm/kafka-mcp-server.git","description":"A Model Context Protocol (MCP) server for Apache Kafka implemented in Go, leveraging franz-go and mcp-go.","language":"Go","stars":53,"topics":["kafka","mcp","mcp-server"],"license":null,"category":"mcp-servers","readme_excerpt":"Kafka MCP Server A Model Context Protocol (MCP) server for Apache Kafka implemented in Go, leveraging franz-go and mcp-go. This server provides an implementation for interacting with Kafka via the MCP protocol, enabling LLM models to perform common Kafka operations through a standardized interface. Overview The Kafka MCP Server bridges the gap between LLM models and Apache Kafka, allowing them to: - Produce and consume messages from topics - List, describe, and manage topics - Monitor and manage consumer groups - Assess cluster health and configuration - Execute standard Kafka operations All through the standardized Model Context Protocol (MCP). Architecture How it works: 1. MCP Clients (AI applications) connect to the Kafka MCP Server via stdio or HTTP transport 2. MCP Server exposes three types of capabilities: - Tools - Direct Kafka operations (produce/consume messages, describe topics, etc.) - Resources - Cluster health reports and diagnostics - Prompts - Pre-configured workflows for common operations 3. Kafka Client Wrapper handles all Kafka communication using the franz-go library 4. Apache Kafka Cluster processes the actual message streaming and storage Transport Modes: - STDIO : Default mode, ideal for local MCP clients (Claude Desktop, Cursor, etc.) - HTTP : Enables remote access with optional OAuth 2.1 authentication Key Features - Kafka Integration : Implementation of common Kafka operations via MCP - Security : - Support for SASL (PLAIN, SCRAM-SHA-256, SCRAM-SHA-5","default_branch":null,"files":null,"tree":[],"storefront":"/r/tuannvm","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/tuannvm/kafka-mcp-server/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}