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

コメント

「その他」の他のコンテンツ