Strimzi MCP Server

🚀 Strimzi MCP 服務器

Strimzi MCP 服務器是一個用於在 Kubernetes 上與 Strimzi Kafka 進行交互的 MCP（模型上下文協議）服務器。它能讓像 Claude 這樣的 AI 助手管理和排查 Strimzi 資源問題，為 Strimzi Kafka 在 Kubernetes 上的管理提供了強大支持。

🚀 快速開始

Strimzi MCP 服務器是一個用於在 Kubernetes 環境中與 Strimzi Kafka 進行交互的工具。它允許 AI 助手（如 Claude）管理和排查 Strimzi 資源。

✨ 主要特性

提供 62 種工具，用於在 Kubernetes 上全面管理 Strimzi Kafka。

Kafka 集群管理

• list_kafkas - 列出跨命名空間的 Kafka 集群
• get_kafka_status - 獲取詳細的集群狀態和條件
• restart_kafka_broker - 通過註解觸發滾動重啟
• get_kafka_listeners - 列出用於連接的監聽器地址
• scale_node_pool - 調整 KafkaNodePool 副本數量

主題操作

• list_topics - 列出 KafkaTopic 資源
• describe_topic - 獲取詳細的主題信息（規範、狀態、配置）
• create_topic - 創建新的 KafkaTopic 資源
• delete_topic - 刪除 KafkaTopic 資源
• update_topic_config - 更新主題分區或配置
• get_unready_topics - 查找有問題的主題
• get_topic_operator_status - 檢查實體操作符 Pod 的健康狀況
• compare_topic_config - 比較主題配置

用戶操作

• list_users - 列出 KafkaUser 資源
• describe_user - 獲取用戶詳細信息（認證、訪問控制列表、配額）
• create_user - 使用認證配置創建新的 KafkaUser
• delete_user - 刪除 KafkaUser 資源
• get_user_credentials - 從生成的 Secret 中獲取憑證
• get_user_operator_status - 檢查用戶操作符容器的健康狀況
• update_user_acls - 顯示/清除訪問控制列表規則
• update_user_quotas - 修改用戶配額
• list_user_acls - 以可讀格式顯示訪問控制列表

集群操作

• list_node_pools - 列出 KafkaNodePool 資源
• describe_node_pool - 獲取節點池詳細信息（角色、節點 ID、存儲）
• get_cluster_operator_status - 檢查集群操作符部署的健康狀況

Kafka 連接

• list_kafka_connects - 列出 KafkaConnect 集群
• describe_kafka_connect - 獲取詳細的 KafkaConnect 信息（插件、構建配置）
• list_connect_plugins - 列出可用的連接器插件
• list_connectors - 列出 KafkaConnector 資源
• describe_connector - 獲取連接器詳細信息（配置、任務、狀態）
• create_connector - 創建新的 KafkaConnector
• delete_connector - 刪除連接器
• pause_connector - 暫停連接器
• resume_connector - 恢復暫停的連接器
• restart_connector - 重啟連接器
• update_connector_config - 更新連接器配置

巡航控制（重新平衡）

• list_rebalances - 列出 KafkaRebalance 資源
• describe_rebalance - 獲取重新平衡詳細信息（優化建議、進度）
• create_rebalance - 創建 KafkaRebalance 資源
• approve_rebalance - 批准重新平衡建議
• stop_rebalance - 停止/取消重新平衡
• refresh_rebalance - 刷新重新平衡建議

Kafka MirrorMaker 2

• list_mirrormaker2s - 列出 KafkaMirrorMaker2 資源
• describe_mirrormaker2 - 獲取 MM2 詳細信息（源/目標集群、連接器）
• create_mirrormaker2 - 創建跨集群複製

Kafka 橋接

• list_bridges - 列出 KafkaBridge 資源（HTTP 訪問）
• describe_bridge - 獲取橋接詳細信息（HTTP 配置、生產者/消費者設置）

可觀測性

• get_kafka_logs - 獲取 Kafka 代理日誌
• get_operator_logs - 獲取操作符日誌
• get_kafka_events - 列出 Kubernetes 事件
• health_check - 全面的集群健康檢查
• describe_kafka_pod - Pod 詳細信息和資源

安全性

• rotate_user_credentials - 輪換用戶憑證
• list_certificates - 列出集群證書
• get_certificate_expiry - 檢查證書到期日期

實用工具

• export_resource_yaml - 將資源導出為 YAML
• get_strimzi_version - 獲取 Strimzi/操作符版本
• list_all_resources - 所有 Strimzi 資源的摘要

📦 安裝指南

選項 1：Claude 代碼插件（推薦）

/plugin marketplace add https://github.com/see-quick/strimzi-mcp-server
/plugin install strimzi-mcp@see-quick-strimzi-mcp-server

該插件在首次使用時會自動下載 JAR 文件。

選項 2：手動安裝

從 GitHub 發佈頁面 下載並進行配置：

claude mcp add strimzi -- java -jar /path/to/strimzi-mcp-server.jar

📚 詳細文檔

構建

mvn package -DskipTests

配置

服務器使用您的本地 kubeconfig（~/.kube/config）連接到 Kubernetes 集群。

要求

• Java 21+
• 安裝了 Strimzi 的 Kubernetes 集群
• 有效的 kubeconfig

📄 許可證

本項目採用 Apache 許可證 2.0。

⚠️ 重要提示

這不是一個官方的 Strimzi 項目，而是一個獨立的、社區驅動的工具。