kafka-mcp-server

Overview

The kafka-mcp-server provides a Model Context Protocol implementation for interacting with Kafka clusters. It exposes tools for listing, creating, and deleting topics, as well as retrieving topic information. The server uses FastMCP framework and supports both development and production configurations. While it currently focuses on topic operations, the project indicates plans to expand to message production, consumption, and consumer group management in future releases.

Try asking AI

After installing, here are 5 things you can ask your AI assistant:

• kafka_initialize_connection

  Connect to Kafka using a properties file

  Try:Use kafka_initialize_connection with your properties file <path>Try:Initialize connection with kafka using the properties file <path>
• kafka_list_topics

  List all topics in the cluster

  Try:Use kafka_list_topics to see all topicsTry:List all the topics
• kafka_create_topic

  Create a new topic

  Try:Use kafka_create_topic with name 'my-topic', partitions 3, replication_factor 1Try:Create me a topic with name 'my-topic'
• kafka_delete_topic

  Delete an existing topic

  Try:Delete the topic named 'old-topic'Try:Use kafka_delete_topic to remove 'test-topic'
• kafka_get_topic_info

  Get detailed information about a topic

  Try:Use kafka_get_topic_info for 'my-topic'Try:Tell me about the partitions in 'customer-data' topic

Comparable tools

Installation

git clone https://github.com/joel-hanson/kafka-mcp-server.git
cd kafka-mcp-server

conda create -n kafka-mcp python=3.10 -y
conda activate kafka-mcp
pip install -r requirements.txt

{
  "mcpServers": {
    "kafka": {
      "command": "python",
      "args": ["/path/to/server.py"]
    }
  }
}

FAQ

How do I connect to Kafka?

Use the kafka_initialize_connection tool with your Kafka properties file path that contains connection details like bootstrap.servers.

Can I produce and consume messages?

Currently the server only supports topic operations. Message production and consumption are planned features for future releases.

Compare kafka-mcp-server with