Strimzi MCP Server
[!NOTE] This is not an official Strimzi project. It is an independent, community-driven tool.
An MCP (Model Context Protocol) server for interacting with Strimzi Kafka on Kubernetes. Enables AI assistants like Claude to manage and troubleshoot Strimzi resources.
Features
62 tools for comprehensive Strimzi Kafka management on Kubernetes.
Kafka Cluster Management
list_kafkas- List Kafka clusters across namespacesget_kafka_status- Get detailed cluster status and conditionsrestart_kafka_broker- Trigger rolling restart via annotationget_kafka_listeners- List listener addresses for connectionsscale_node_pool- Adjust KafkaNodePool replicas
Topic Operator
list_topics- List KafkaTopic resourcesdescribe_topic- Get detailed topic info (spec, status, config)create_topic- Create new KafkaTopic resourcesdelete_topic- Delete KafkaTopic resourcesupdate_topic_config- Update topic partitions or configurationget_unready_topics- Find topics with issuesget_topic_operator_status- Check entity-operator pod healthcompare_topic_config- Compare topic configurations
User Operator
list_users- List KafkaUser resourcesdescribe_user- Get user details (authentication, ACLs, quotas)create_user- Create new KafkaUser with authentication configdelete_user- Delete KafkaUser resourcesget_user_credentials- Get credentials from generated Secretget_user_operator_status- Check user-operator container healthupdate_user_acls- Show/clear ACL rulesupdate_user_quotas- Modify user quotaslist_user_acls- Display ACLs in readable format
Cluster Operator
list_node_pools- List KafkaNodePool resourcesdescribe_node_pool- Get node pool details (roles, node IDs, storage)get_cluster_operator_status- Check Cluster Operator deployment health
Kafka Connect
list_kafka_connects- List KafkaConnect clustersdescribe_kafka_connect- Get detailed KafkaConnect info (plugins, build config)list_connect_plugins- List available connector pluginslist_connectors- List KafkaConnector resourcesdescribe_connector- Get connector details (config, tasks, status)create_connector- Create new KafkaConnectordelete_connector- Delete a connectorpause_connector- Pause a connectorresume_connector- Resume a paused connectorrestart_connector- Restart a connectorupdate_connector_config- Update connector configuration
Cruise Control (Rebalancing)
list_rebalances- List KafkaRebalance resourcesdescribe_rebalance- Get rebalance details (optimization proposal, progress)create_rebalance- Create KafkaRebalance resourceapprove_rebalance- Approve a rebalance proposalstop_rebalance- Stop/cancel a rebalancerefresh_rebalance- Refresh a rebalance proposal
Kafka MirrorMaker 2
list_mirrormaker2s- List KafkaMirrorMaker2 resourcesdescribe_mirrormaker2- Get MM2 details (source/target clusters, connectors)create_mirrormaker2- Create cross-cluster replication
Kafka Bridge
list_bridges- List KafkaBridge resources (HTTP access)describe_bridge- Get bridge details (HTTP config, producer/consumer settings)
Observability
get_kafka_logs- Fetch Kafka broker logsget_operator_logs- Fetch operator logsget_kafka_events- List Kubernetes eventshealth_check- Comprehensive cluster health checkdescribe_kafka_pod- Pod details and resources
Security
rotate_user_credentials- Rotate user credentialslist_certificates- List cluster certificatesget_certificate_expiry- Check certificate expiry dates
Utilities
export_resource_yaml- Export resources as YAMLget_strimzi_version- Get Strimzi/operator versionslist_all_resources- Summary of all Strimzi resources
Build
mvn package -DskipTests
Installation
Option 1: Claude Code Plugin (Recommended)
/plugin marketplace add https://github.com/see-quick/strimzi-mcp-server
/plugin install strimzi-mcp@see-quick-strimzi-mcp-server
The plugin automatically downloads the jar on first use.
Option 2: Manual
Download from GitHub Releases and configure:
claude mcp add strimzi -- java -jar /path/to/strimzi-mcp-server.jar
Configuration
The server uses your local kubeconfig (~/.kube/config) to connect to the Kubernetes cluster.
Requirements
- Java 21+
- Kubernetes cluster with Strimzi installed
- Valid kubeconfig
License
Apache License 2.0
