wklee610/kafka-mcp
by Various
MCP Server for Apache Kafka
MCP
wklee610/kafka-mcp
Added 1 June 2026
Overview
wklee610/kafka-mcp is an MCP server that provides an interface to interact with Apache Kafka. It allows AI agents or tools to send and receive messages from Kafka topics using the Model Context Protocol. The implementation is in Python.
Best for
Best for
Developers building AI agent workflows that need a lightweight Kafka interface via MCP
Use cases
- Connecting AI agents to Kafka streams for real-time data processing
- Producing and consuming messages programmatically via MCP-compatible tools
- Integrating Kafka with MCP workflows for event-driven agent interactions
Notes
wklee610/kafka-mcp is an MCP server that provides an interface to interact with Apache Kafka. It allows AI agents or tools to send and receive messages from Kafka topics using the Model Context Protocol. The implementation is in Python.
11 stars on GitHub. Last updated 2026-03-08. Licensed Apache-2.0.
Use cases
- Connecting AI agents to Kafka streams for real-time data processing
- Producing and consuming messages programmatically via MCP-compatible tools
- Integrating Kafka with MCP workflows for event-driven agent interactions
Pros
- Lightweight Python implementation with simple setup
- Provides a standardized MCP interface for Kafka
- Open source and easy to customize
Cons
- Low star count suggests limited adoption or early-stage development
- May lack comprehensive documentation or community support
- Only covers basic Kafka operations; advanced features are not guaranteed
Indexed from awesome-mcp-servers-punkpeye and enriched against its public facts.
Pros
- Lightweight Python implementation with simple setup
- Provides a standardized MCP interface for Kafka
- Open source and easy to customize
Cons
- Low star count suggests limited adoption or early-stage development
- May lack comprehensive documentation or community support
- Only covers basic Kafka operations; advanced features are not guaranteed
Pairs with
Other entries in the index that connect to this one. Click through to see the chain.