Warning
This project is in early alpha and under active development. APIs, tool definitions, and configuration may change without notice.
Talk to your streaming platform. StreamsHub MCP gives AI assistants direct access to your Kubernetes-based streaming infrastructure through the Model Context Protocol. Deploy only the servers you need — each component of your streaming stack gets its own MCP server.
Works with any MCP-compatible client including Claude Code, Claude Desktop, VS Code, Copilot, and more.
| Server | Description |
|---|---|
| Strimzi MCP | Manage and troubleshoot Strimzi-managed Kafka clusters on Kubernetes |
Each server has its own README with full documentation — available tools, resource templates, deployment, and configuration.
StreamsHub MCP servers go beyond wrapping APIs as tool calls. They leverage the full MCP specification to create an AI-native operations experience:
- Prompt templates — structured diagnostic workflows that guide the LLM step-by-step through complex troubleshooting, telling it exactly which tools to call and in what order
- Resource templates — live cluster state exposed as structured context that clients can attach directly to conversations, giving the LLM immediate visibility without requiring tool calls
- Resource subscriptions — Kubernetes watches that push real-time notifications when cluster state changes, enabling reactive agents that detect and investigate issues automatically
- Completions — dynamic autocomplete for parameters (namespaces, cluster names, topics) powered by live Kubernetes queries
- Progress and cancellation — long-running operations like log collection report progress back to the client and support mid-operation cancellation
Pick an MCP server from the table above and follow its README. Each server can be deployed independently as a standalone application or container.
- Quarkus — cloud-native Java framework
- Fabric8 Kubernetes Client — Kubernetes API access
- Quarkus MCP Server — MCP protocol implementation
mvn compile # Compile all modules (includes checkstyle)
mvn test # Run unit testsContributions are welcome. To get started:
- Fork the repository and create a feature branch
- Run
mvn compileto verify checkstyle compliance - Run
mvn testto ensure all tests pass - Open a pull request