Kafka Kubernetes
Automates Kafka cluster deployment, scaling, and management within Kubernetes environments using Anton Abyzov's expertise.
Install on your platform
We auto-selected Claude Code based on this skill’s supported platforms.
Run in terminal (recommended)
claude mcp add kafka-kubernetes npx -- -y @trustedskills/kafka-kubernetes
Or manually add to ~/.claude/settings.json
{
"mcpServers": {
"kafka-kubernetes": {
"command": "npx",
"args": [
"-y",
"@trustedskills/kafka-kubernetes"
]
}
}
}Requires Claude Code (claude CLI). Run claude --version to verify your install.
About This Skill
What it does
This skill enables AI agents to interact with and manage Kafka clusters deployed within Kubernetes environments. It facilitates tasks like creating, configuring, and monitoring Kafka topics, brokers, and consumers. The skill provides a streamlined interface for managing complex distributed streaming platforms directly from an agent's workflow.
When to use it
- Automated Infrastructure Provisioning: Automatically deploy and configure new Kafka clusters in Kubernetes based on defined requirements.
- Real-time Data Pipeline Management: Monitor the health of existing data pipelines built using Kafka within a Kubernetes cluster, and automatically adjust configurations as needed.
- Troubleshooting & Debugging: Quickly diagnose issues with Kafka brokers or topics by querying their status and configuration from within a Kubernetes environment.
- Scaling Streaming Applications: Dynamically scale Kafka resources (topics, partitions) based on real-time load metrics observed in the Kubernetes cluster.
Key capabilities
- Kafka topic creation/deletion
- Broker management within Kubernetes
- Consumer group monitoring
- Configuration retrieval and modification
Example prompts
- "Create a new Kafka topic named 'orders' with 3 partitions."
- "Show me the status of all Kafka brokers in the 'production' namespace."
- "Scale the number of partitions for the 'transactions' topic to 5."
- “What is the current lag for consumer group ‘payments’?”
Tips & gotchas
The agent requires appropriate Kubernetes credentials and permissions to interact with the cluster. Ensure the skill has access to the necessary resources before attempting any management operations.
Tags
TrustedSkills Verification
Unlike other registries that point to live repositories, TrustedSkills pins every skill to a verified commit hash. This protects you from malicious updates — what you install today is exactly what was reviewed and verified.
Security Audits
| Gen Agent Trust Hub | Pass |
| Socket | Pass |
| Snyk | Pass |
🌐 Community
Passed automated security scans.