{"repo":"wklee610/kafka-mcp","free":true,"listed":false,"github":"https://github.com/wklee610/kafka-mcp","clone":"git clone https://github.com/wklee610/kafka-mcp.git","description":"MCP Server for Apache Kafka","language":"Python","stars":12,"topics":["claude-desktop","kafka","mcp","mcp-server","apache-kafka","apache-kafka-consumer","apache-kafka-producer","kafka-connector","kafka-python","mcp-servers"],"license":"Apache-2.0","category":"mcp-servers","readme_excerpt":"Kafka MCP Server --- An MCP server implementation for Kafka, allowing LLMs to interact with and manage Kafka clusters. Features - Cluster Management : View broker details describe cluster , describe brokers . - Topic Management : List list topics , create create topic , delete delete topic , describe describe topic , and increase partitions create partitions . - Configuration Management : View describe configs and modify alter configs dynamic configs for topics, brokers, and groups. - Consumer Groups : List list consumer groups , describe describe consumer group , and securely manage offsets with reset consumer group offset and rewind consumer group offset by timestamp . Advanced tools include state validation, dry runs, and execution audit logging. - Messaging : Consume messages consume messages (from beginning, latest, or specific offsets) and produce messages produce message . Prerequisites - Python 3.10+ - uv package manager (recommended) - A running Kafka cluster (e.g., local Docker, Confluent Cloud, etc.) Installation 1. Clone the repository. 2. Install dependencies: Configuration The server requires the KAFKA BOOTSTRAP SERVERS environment variable. - KAFKA BOOTSTRAP SERVERS : Comma-separated list of broker urls (e.g., localhost:9092 ). - KAFKA CLIENT ID : (Optional) Client ID for connection (default: kafka-mcp ). Usage Running the Server You can run the server directly using uv or python , or use Docker. Using uv (Recommended) Using Docker 1. Build the Docker image: 2.","default_branch":null,"files":null,"tree":[],"storefront":"/r/wklee610","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/wklee610/kafka-mcp/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."}