kafka_mcp_server
If you are the rightful owner of kafka_mcp_server and would like to certify it and/or have it hosted online, please leave a comment on the right or send an email to henry@mcphub.com.
A Message Context Protocol (MCP) server that integrates with Apache Kafka to provide publish and consume functionalities for LLM and Agentic applications.
The Kafka MCP Server is designed to facilitate the interaction between AI models and Kafka topics through a standardized interface. It provides functionalities for publishing messages to Kafka topics and consuming messages from them. The server is implemented in Python and requires an Apache Kafka instance to operate. It is particularly useful for applications that need to handle large volumes of data in real-time, such as those involving language models and agentic systems. The server supports different transport options, including standard input/output and server-sent events, making it versatile for various deployment scenarios. Configuration is managed through environment variables, allowing for easy customization of Kafka settings and tool descriptions.
Features
- Standardized interface for AI models to interact with Kafka topics.
- Supports publishing and consuming messages from Kafka topics.
- Configurable through environment variables for easy setup.
- Multiple transport options including stdio and sse.
- Integration capability with platforms like Claude Desktop.
Tools
kafka-publish
Publish information to configured Kafka topics
kafka-consume
Once the message is read, the same set of IDs cannot be read again)
