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.
MCP Kafka Processor
@boufnichel
Basic information
About MCP Kafka Processor
An MCP server for processing Kafka events and enabling LLMs to interact with event streams
MCP Kafka Processor config
No standard config provided
This server doesn't expose a parseable MCP config block in its README. See the repository for install instructions.
RepositoryMCP Kafka Processor tools
Tool list not available yet
This listing does not currently have a tool list to display. This does not mean the server has no tools; check its documentation for supported capabilities.
We auto-extract tools from the README. The maintainer can list them under a ## Tools heading to populate this section.
Overview
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
Frequently asked questions
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.
More Productivity MCP servers
crosscode-cli
amsultan2010Multiplayer coding in the agentic era through an MCP server for real-time codebase sync between your agents.
1
TripLedger
Pianosa LabsTripLedger is a personal travel ledger for AI assistants. Connect Claude, ChatGPT, Cursor or any MCP client to log journeys, stays and travel expenses (including from booking emails), then ask for tax-residency day count
WhatsMCP
whatsmcpWhatsMCP — WhatsApp for AI agents. Put an AI agent on a real WhatsApp number. Expose regular WhatsApp accounts to your LLM agents over JSON-RPC. A complete Model Context Protocol server that turns phone numbers into addr
EQIQs
EQIQsEQIQs brings working-style and compatibility insights into Claude. Managers and coaches can take or send a short assessment, compare two people, get a read on a team of up to 12, prepare for meetings with tips that fit t
1
Twistly AI Presentation Maker
TwistlyTwistly turns your ideas, notes, and documents into ready-to-edit PowerPoint presentations. Describe a topic, paste in text, or share a file (PDF, DOCX, PPTX, or TXT), and Twistly builds a structured deck of up to 50 sli
Comments