Strimzi MCP Server

Strimzi MCP服务器

\[！注意\] 这不是官方的 斯特里姆斯 项目。它是一个独立的、由社区驱动的工具。

用于与以下对象交互的MCP（模型上下文协议）服务器 斯特里姆斯 Kubernetes上的Kafka。 使像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 -列出卡夫卡主题资源
• describe_topic -获取详细的主题信息（规格、状态、配置）
• create_topic -创建新的KafkaTopic资源
• delete_topic -删除KafkaTopic资源
• update_topic_config -更新主题分区或配置
• get_unready_topics -查找有问题的主题
• get_topic_operator_status -检查实体运算符pod运行状况
• compare_topic_config -比较主题配置

用户操作员

• list_users -列出Kafka用户资源
• describe_user -获取用户详细信息（身份验证、ACL、配额）
• create_user -使用身份验证配置创建新的KafkaUser
• delete_user -删除Kafka用户资源
• get_user_credentials -从生成的Secret获取凭据
• get_user_operator_status -检查用户操作员容器运行状况
• update_user_acls -显示/清除ACL规则
• update_user_quotas -修改用户配额
• list_user_acls -以可读格式显示ACL

集群运营商

• 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 -创建跨群集复制

卡夫卡桥

• 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所有资源汇总

构建

mvn package -DskipTests

安装

选项1:克劳德代码插件（推荐）

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

该插件在首次使用时会自动下载jar。

选项2：手动

下载自 并配置：

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

配置

服务器使用本地kubeconfig(~/.kube/config)连接到Kubernetes集群。

需求

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

许可证

Apache许可证2.0