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 项目，而是一个独立的、社区驱动的工具。