广告合作
MCP.so
登录

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

常见问题

1

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.

2

What are the prerequisites for using it?

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

3

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

4

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.

5

Can I limit how many messages are consumed?

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

评论

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

Buzzmark

Piik Labs AB

Buzzmark is a ghostwriter that writes, plans and schedules social media posts for founders and growing businesses. It reads your website and products first, so the first draft already sounds like you, and it keeps learni

Kapa

kapa-ai

Index your docs, help center, support tickets, wikis and code into one fast knowledge base. Connect Zendesk, Confluence, Notion, GitHub, Slack, Google Drive, Jira, Salesforce, websites, PDFs and 15+ more sources. Kapa sy

Etincel

AIStoryHub

Find the AI tells in your prose. Deterministic, local, runs in CI. MCP server + CLI + Action.

6

Local MCP (LMCP)

lanchuske

Local tools that let your AI use Mail, Calendar, Contacts, Teams, Slack, WhatsApp, OneDrive, Google Drive, Notion, Outlook and Office files on Mac and Windows. Runs on your computer.

54

fixRAgent maintenance triage

AR Logic LLC

One photo of a building problem becomes a Triage Profile in about ten seconds: what the asset is, how urgent it is (EMERGENCY, TODAY, THIS WEEK or WHENEVER), which trade to call, and what to tell the resident. For proper

广告合作