kafka-mcp-server

概述

kafka-mcp-server 是一个用于与Kafka集群交互的Model Context协议实现。它提供了列出、创建和删除主题以及检索主题信息的工具。该服务器使用FastMCP框架，支持开发和生产配置。虽然当前主要关注主题操作，但项目计划在未来扩展到消息生产、消费和消费者组管理功能。

试试问 AI

装完之后，这里有 5 个你可以让 AI 做的事：

• kafka_initialize_connection

  Connect to Kafka using a properties file

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

  List all topics in the cluster

  试试:Use kafka_list_topics to see all topics试试:List all the topics
• kafka_create_topic

  Create a new topic

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

  Delete an existing topic

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

  Get detailed information about a topic

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

可对比工具

安装

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

如何连接到Kafka？

使用kafka_initialize_connection工具，提供包含连接详情（如bootstrap.servers）的Kafka属性文件路径。

可以生产和消费消息吗？

目前服务器仅支持主题操作。消息生产和消费是计划中的未来功能。

kafka-mcp-server 对比