mcp-kafka-processor
0
The MCP Kafka Processor is a server implementation that leverages Kafka for event processing, enabling integration with Large Language Models via the Model Context Protocol. It facilitates message publishing and consumption across Kafka topics with TypeScript support for a type-safe experience.
MCP Kafka Processor
An MCP server implementation that provides event processing capabilities through Kafka integration. This server allows Large Language Models to interact with Kafka topics through the Model Context Protocol.
Features
- Publish events to Kafka topics
- Consume events from Kafka topics
- Easy integration with Claude Desktop and other MCP clients
- Type-safe implementation using TypeScript
Prerequisites
- Node.js 16 or higher
- Kafka broker accessible
- TypeScript knowledge for development
Configuration
The server can be configured using environment variables such as KAFKA_BROKERS.
Usage with Claude Desktop
Add the following to your Claude Desktop configuration.
Available Tools
publish-event
Publishes a message to a specified Kafka topic.
consume-events
Consumes messages from a specified Kafka topic.