Credits

Name: Credits
Author: CefBoud

@CefBoud

代码仓库主页

关于 Credits

暂无概览

基本信息

分类

其他

运行时

传输方式

stdio

发布者

CefBoud

配置

使用下面的配置,将此服务器添加到你的 MCP 客户端。

{
  "mcpServers": {
    "kafka": {
      "command": "docker",
      "args": [
        "run",
        "-i",
        "--rm",
        "-e",
        "KAFKA_MCP_BOOTSTRAP_SERVERS",
        "ghcr.io/cefboud/kafka-mcp-server"
      ],
      "env": {
        "KAFKA_MCP_BOOTSTRAP_SERVERS": "localhost:9092"
      }
    }
  }
}

工具

未检测到工具

工具是从 README 中自动提取的。维护者可以在 ## Tools 标题下列出工具,即可填充这部分内容。

概览

What is Kafka MCP Server?

The Kafka MCP Server is a Model Context Protocol (MCP) server that provides integration with Apache Kafka, enabling interaction with a Kafka cluster using natural language via LLMs.

How to use Kafka MCP Server?

Requires Docker or Go to run locally, and access to a Kafka cluster. Configure with the KAFKA_MCP_BOOTSTRAP_SERVERS environment variable or --bootstrap-servers flag. Can be run via Docker image ghcr.io/cefboud/kafka-mcp-server or built from source.

Key features of Kafka MCP Server

List and create topics
Consume and produce messages
Describe cluster (brokers and controller)
List consumer groups and their lag
Get topic's earliest and latest offsets
MultiplexTool for batching sequential tool calls

Use cases of Kafka MCP Server

Monitor Kafka topics and consumer groups via natural language
Automate topic creation and message production from LLM chat
Debug cluster state and broker information interactively
Execute multi-step Kafka operations in a single request using MultiplexTool

FAQ from Kafka MCP Server

What are the prerequisites?

Docker or Go, and a running Kafka cluster. The quickstart uses docker run -p 9092:9092 apache/kafka:4.0.0.

How do I connect to my Kafka cluster?

Set the KAFKA_MCP_BOOTSTRAP_SERVERS environment variable or the --bootstrap-servers CLI flag.

Can I restrict the server to read-only?

Yes, use the --read-only flag to limit the server to read-only operations.

What is MultiplexTool?

A tool that batches multiple sequential tool calls into one request, with optional dynamic dependencies resolved via LLM prompts (currently Gemini requires GEMINI_API_KEY).