mcp-kafka

mcp-kafka

3.5

If you are the rightful owner of mcp-kafka 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 Model Context Protocol (MCP) server for performing Kafka client operations from AI assistants.

mcp-kafka provides a bridge between AI assistants and Apache Kafka, allowing them to interact with Kafka clusters through the Model Context Protocol. This tool enables AI assistants to create, manage, and interact with Kafka topics and messages directly. It supports operations such as creating, listing, deleting, and describing Kafka topics, as well as producing and consuming messages. The server is designed to facilitate seamless communication between AI models and Kafka, making it easier to manage data streams and message queues. With mcp-kafka, users can leverage the power of Kafka in their AI applications, enhancing data processing capabilities and enabling real-time data interaction.

Features

  • Create Topic: Create a new Kafka topic with configurable partitions and replication factor
  • List Topics: Get a list of all available Kafka topics in the cluster
  • Delete Topic: Remove an existing Kafka topic
  • Describe Topic: Get detailed information about a specific topic, including partition details
  • Produce Message: Send messages to a Kafka topic with support for message keys and headers
  • Consume Messages: Read messages from a Kafka topic with configurable timeout