MCP.so
登录

Kafka MCP Server

@MCP-Mirror

代码仓库

关于 Kafka MCP Server

Mirror of

#kafka#mcp-server#message-protocol

基本信息

分类

其他

许可证

Apache-2.0 license

运行时

python

传输方式

stdio

发布者

MCP-Mirror

配置

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

{
  "mcpServers": {
    "pavanjava_kafka_mcp_server": {
      "command": "python",
      "args": [
        "-m",
        "venv",
        "venv"
      ]
    }
  }
}

工具

未检测到工具

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

概览

What is Kafka MCP Server?

A Message Context Protocol (MCP) server that integrates with Apache Kafka, providing publish and consume functionalities for LLM and agentic applications. It allows AI models to interact with Kafka topics through a standardized interface.

How to use Kafka MCP Server?

Install dependencies (pip install -r requirements.txt), configure a .env file with Kafka connection settings, then run python main.py --transport stdio. Supports stdio (default) and sse transports. Can be integrated with Claude Desktop via its MCP configuration.

Key features of Kafka MCP Server

  • Publish messages to a configured Kafka topic
  • Consume messages from a configured Kafka topic
  • Supports configurable Kafka bootstrap servers, topic name, and consumer group
  • Customizable tool descriptions via environment variables
  • Runs over stdio or SSE transports

Use cases of Kafka MCP Server

  • Enable an LLM to publish structured data to a Kafka topic
  • Allow an AI agent to consume and process messages from a Kafka stream
  • Integrate Kafka messaging into a Claude Desktop workflow

FAQ from Kafka MCP Server

What are the prerequisites?

Python 3.8+, a running Apache Kafka instance, and installation of dependencies aiokafka, python-dotenv, pydantic-settings, and mcp-server.

How do I configure the server?

Create a .env file in the project root with KAFKA_BOOTSTRAP_SERVERS, TOPIC_NAME, IS_TOPIC_READ_FROM_BEGINNING, and DEFAULT_GROUP_ID_FOR_CONSUMER. Optional TOOL_PUBLISH_DESCRIPTION and TOOL_CONSUME_DESCRIPTION can override tool descriptions.

What transport options are available?

The server supports stdio (standard input/output) and sse (Server-Sent Events). Use the --transport flag when running main.py.

Can I customize the tool names or descriptions?

Yes, by setting TOOL_PUBLISH_DESCRIPTION and TOOL_CONSUME_DESCRIPTION in the .env file you can provide custom descriptions for the publish and consume tools.

Are consumed messages re-readable?

No. Once a message is read from the topic it cannot be read again using the same consumer group. The server uses a configurable consumer group (DEFAULT_GROUP_ID_FOR_CONSUMER).

评论

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

ACI: Open-Source Infra to Power Unified MCP Servers

aipotheosis-labs

ACI.dev is the open source tool-calling platform that hooks up 600+ tools into any agentic IDE or custom AI agent through direct function calling or a unified MCP server. The birthplace of VibeOps.

4.8K

FastMCP v2 🚀

jlowin

🚀 The fast, Pythonic way to build MCP servers and clients.

26.0K

MaxKB

1Panel-dev

🔥 MaxKB is an open-source platform for building enterprise-grade agents. 强大易用的开源企业级智能体平台。

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

MCP Go 🚀

mark3labs

A Go implementation of the Model Context Protocol (MCP), enabling seamless integration between LLM applications and external data sources and tools.

8.9K