MCP.so
登录

Credits

@CefBoud

代码仓库主页

关于 Credits

暂无概览

基本信息

分类

其他

运行时

go

传输方式

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).

What authentication is supported?

The README does not mention authentication; it assumes a plain connection (e.g., to localhost:9092).

评论

其他 分类下的更多 MCP 服务器

EverArt

modelcontextprotocol

Model Context Protocol Servers

88.1K

Codelf

unbug

A search tool helps dev to solve the naming things problem.

14.2K

Nginx UI

0xJacky

Yet another WebUI for Nginx

11.3K

Awesome Mlops

visenger

A curated list of references for MLOps

14.0K

Unity MCP ✨

justinpbarnett

Unity MCP acts as a bridge between AI assistants and your Unity Editor. Give your LLM tools to manage assets, control scenes, edit scripts, and automate tasks within Unity.

12.2K