MCP Kafka Processor

@boufnichel

代码仓库

基本信息

分类

生产力

传输方式

stdio

作者

boufnichel

关于 MCP Kafka Processor

An MCP server for processing Kafka events and enabling LLMs to interact with event streams

#mcp-kafka-processor#kafka-events#llm-integration

MCP Kafka Processor 配置

暂无标准配置

该服务器的 README 中没有可解析的 MCP 配置块，请前往代码仓库查看安装说明。

代码仓库

MCP Kafka Processor 工具

工具列表暂未提供

当前收录暂时没有可展示的工具列表，不代表服务没有工具。请查阅项目文档了解支持的能力。

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

概览

What is Mcp Kafka Processor?

Mcp Kafka Processor is an MCP server that provides event processing capabilities through Kafka integration. It allows Large Language Models to interact with Kafka topics through the Model Context Protocol, enabling publish and consume operations for event-driven AI workflows.

How to use Mcp Kafka Processor?

Clone the repository, install dependencies with npm install, and build with npm run build. Configure the Kafka broker using the KAFKA_BROKERS environment variable (default localhost:9092), then add the server to your Claude Desktop configuration by specifying the build/index.js path and environment variable in claude_desktop_config.json.

Key features of Mcp Kafka Processor

Publish events to Kafka topics
Consume events from Kafka topics
Easy integration with Claude Desktop and MCP clients
Type-safe implementation using TypeScript
Configurable via environment variables

Use cases of Mcp Kafka Processor

Publishing messages from an LLM to a Kafka topic for downstream processing
Consuming Kafka events and delivering them to an AI assistant for analysis
Automating event-driven workflows with AI as the decision engine
Enabling real-time data pipelines where AI consumes or produces Kafka messages

常见问题

What is the purpose of this server?

It enables LLMs to publish and consume events from Kafka topics through the MCP protocol, bridging AI agents with Kafka-based event streams.

What are the prerequisites for using it?

Node.js 16 or higher, an accessible Kafka broker, and TypeScript knowledge for development.

How do I configure the Kafka broker connection?

Set the `KAFKA_BROKERS` environment variable to a comma-separated list of broker addresses (default is `localhost:9092`).

What tools does the server provide?

Two tools: `publish-event` (send a message to a topic) and `consume-events` (receive messages from a topic). Both require a `topic` parameter; consume-events also accepts an optional `maxMessages` parameter.

Can I limit how many messages are consumed?

Yes, the `consume-events` tool has a `maxMessages` parameter that defaults to 10.

生产力分类下的更多 MCP 服务器

JobYap

JobYap aggregates job postings directly from tech companies' official careers sites and gives every posting a public discussion thread, with salaries, locations and full descriptions.

Postbye

Postbye Team

Postbye MCP server: cancellation letters, mailing addresses and how-to-cancel guides for 8,600+ companies

Comuna

Comuna is a free-forever team workspace (Kanban, table, calendar, Gantt, chat, notes, wiki) where your AI is a real board member. Connect Claude or ChatGPT via MCP in 60 seconds: 80+ tools to work cards under its own ide

Fluenta

Fluenta Tech LLC

Remote MCP server that scores business ideas on six live market signals. Run an Idea X-Ray from Claude, Cursor or any MCP client and get a Launch Readiness Score (LRS) across demand, pain, competition, monetisation, timi

docket

Evernow GmbH

Projects, tickets, time and budgets for agencies. Ask about your week, book time, run stopwatches and work on tickets — with exactly the access you have in docket.