mcp-kafka

mcp-kafka

3.3
cloud_platforms

If you are the rightful owner of mcp-kafka and would like to certify it and/or have it hosted online, please leave a comment on the right or send an email to henry@mcphub.com.

mcp-kafka is a server-side implementation of the Model Context Protocol for Apache Kafka, enabling language models to interact with Kafka and its ecosystem.

Overview

mcp-kafka is a server-side implementation of the model context protocol (MCP) for Apache Kafka. It allows language models (LLM/SLM) to reliably interact with Kafka & its ecosystem, including Kafka Connect, Burrow, & Cruise Control.

NOTE: This is a WIP, changes/potential errors are expected.

Features

The server supports capabilities based on the core Kafka APIs, excluding Streams (for now), along with the Burrow & Cruise Control REST APIs.

TODO

  • Use asyncio and aiohttp.
  • Set env config values in the data class.
  • Finish admin/consumer/producer API support.
  • Support Burrow API.
  • Support CC API.
  • Service + integration tests.
  • Publish to PyPI (uv pip install mcp-kafka)
  • Test Dockerfile & push to Dockerhub (docker pull bkpowers/mcp-kafka)
  • Usage/config/deployment options + demo in README.
  • Consider Strimzi/kcctl integrations.
  • Prompts with auto-complete support for certain resources/tools.

MCP Capabilities

Tools
Kafka
  • consume
  • produce
  • describe_kafka_cluster
  • describe_kafka_topics
  • describe_kafka_consumer_groups
  • describe_kafka_delegation_tokens
  • describe_kafka_log_dirs
  • describe_kafka_configs
  • describe_kafka_acls
Kafka Connect
  • get_kafka_connect_cluster_info
  • get_kafka_connect_config
  • get_kafka_connect_connectors
  • get_kafka_connect_connector_plugins
  • get_kafka_connect_loggers
Burrow
  • burrow_healthcheck
  • burrow_list_clusters
  • burrow_describe_cluster
  • burrow_list_consumers_with_group_detail
  • burrow_list_topics
  • burrow_check_consumer_group_status
Cruise Control
  • cruise_control_get_state
  • cruise_control_get_kafka_cluster_load
  • cruise_control_get_partition_resource_utilization_and_load
  • cruise_control_get_partition_and_replica_state
  • cruise_control_get_optimization_proposals
  • cruise_control_get_user_request_result
Resources
  • topic, connector, consumer group
Prompts

Usage / Configuration

  1. Claude Desktop
  2. Cursor
  3. Windsurf
  4. Langchain MCP adapter
  5. Azure OpenAI

Environment Variables

Supported APIs are (currently) enabled by the presence of their specific environment variable. If none are present, the server responds as empty. If 1 or more variables are present, then the respective tools are also present.

  • KAFKA_BOOTSTRAP_SERVERS: Kafka Admin, Consumer, Producer APIs
  • KAFKA_CONNECT_API_URL: Kafka Connect API
  • KAFKA_BURROW_API_URL: Burrow API
  • KAFKA_CRUISE_CONTROL_API_URL: Cruise Control API

Related MCP Servers

View all cloud_platforms servers →
firecrawl-mcp-server

firecrawl-mcp-server

4.7

by mendableai

Firecrawl MCP Server is a Model Context Protocol server implementation that integrates with Firecrawl for web scraping capabilities.

browser_automation
mkp

mkp

3.8

by StacklokLabs

MKP is a Model Context Protocol (MCP) server for Kubernetes that allows LLM-powered applications to interact with Kubernetes clusters.

cloud_platforms
Nx MCP Server

Nx MCP Server

3.8

by nrwl

A Model Context Protocol server implementation for Nx, providing LLMs with deep access to monorepo structures.

cloud_platforms
mcp-atlassian

mcp-atlassian

3.8

by sooperset

Model Context Protocol (MCP) server for Atlassian products (Confluence and Jira). This integration supports both Confluence & Jira Cloud and Server/Data Center deployments.

cloud_platforms
hyper-mcp

hyper-mcp

3.7

by tuananh

hyper-mcp is a fast, secure MCP server that extends its capabilities through WebAssembly plugins.

ai_chatbot
HubSpot

HubSpot

3.7

by PipedreamHQ

Pipedream MCP Server is a reference implementation that allows you to run your own MCP server for over 2,500 apps and APIs, powered by Pipedream Connect.

cloud_platforms
notion-mcp-server

notion-mcp-server

3.7

by makenotion

This project implements an MCP server for the Notion API, allowing integration with LLMs.

databases
k8m

k8m

3.7

by weibaohui

K8M is an AI-driven lightweight Kubernetes dashboard designed to simplify cluster management.

ai_chatbot
cos-mcp

cos-mcp

3.7

by Tencent

Tencent Cloud COS MCP Server allows large models to quickly access Tencent Cloud Storage (COS) and Data Processing (CI) capabilities without coding.

cloud_platforms
mcp-sse

mcp-sse

3.7

by sidharthrajaram

This document describes an SSE-based MCP server and client setup for weather data retrieval using the Model Context Protocol.

cloud_platforms
mem0-mcp

mem0-mcp

3.7

by mem0ai

This demonstrates a structured approach for using an MCP server with mem0 to manage coding preferences efficiently.

developer_tools
mcp-server-azure-devops

mcp-server-azure-devops

3.7

by Tiberriver256

A Model Context Protocol (MCP) server implementation for Azure DevOps, allowing AI assistants to interact with Azure DevOps APIs through a standardized protocol.

cloud_platforms
tfmcp

tfmcp

3.6

by nwiizo

tfmcp is a command-line tool that facilitates interaction with Terraform using the Model Context Protocol (MCP), enabling LLMs to manage Terraform environments.

cloud_platforms
mcp-k8s-go

mcp-k8s-go

3.6

by strowk

Golang-based MCP server connecting to Kubernetes, providing a range of functionalities to interact with Kubernetes resources.

cloud_platforms
win-cli-mcp-server

win-cli-mcp-server

3.6

by SimonB97

MCP server for secure command-line interactions on Windows systems, enabling controlled access to PowerShell, CMD, Git Bash shells, and remote systems via SSH.

os_automation
ocireg-mcp

ocireg-mcp

3.6

by StacklokLabs

An MCP server that provides tools for querying OCI registries and image references.

cloud_platforms
12306-mcp

12306-mcp

3.6

by Joooook

A 12306 ticket search server based on the Model Context Protocol (MCP). The server provides a simple API interface that allows users to search for 12306 tickets.

cloud_platforms
xperience-community-mcp-server

xperience-community-mcp-server

3.6

by seangwright

Xperience Community MCP Server is a .NET-based MCP Server tailored for Xperience by Kentico projects, enhancing AI agent capabilities.

cloud_platforms
emcee

emcee

3.6

by loopwork

emcee is a tool that provides a Model Context Protocol (MCP) server for any web application with an OpenAPI specification.

developer_tools
figma-mcp-server

figma-mcp-server

3.6

by TimHolden

A Model Context Protocol (MCP) server that provides integration with Figma's API through Claude and other MCP-compatible clients.

cloud_platforms
argocd-mcp

argocd-mcp

3.6

by akuity

Argo CD MCP Server is an implementation of the Model Context Protocol server for Argo CD, enabling AI assistants to interact with Argo CD applications through natural language.

cloud_platforms
api200

api200

3.6

by API-200

API 200 is an open-source platform designed to streamline the integration and management of third-party APIs, offering features like auto-generated code, authentication, caching, and error handling.

cloud_platforms
lokka

lokka

3.6

by merill

Lokka is a model-context-protocol server designed for interacting with Microsoft Graph and Azure RM APIs, enabling AI-driven management of Azure and Microsoft 365 tenants.

cloud_platforms
Lambda-MCP-Server

Lambda-MCP-Server

3.6

by mikegc-aws

This project demonstrates a serverless MCP server using AWS Lambda, showcasing streamable HTTP support and integration with Amazon Bedrock.

cloud_platforms
llamacloud-mcp

llamacloud-mcp

3.6

by run-llama

This repository demonstrates how to create an MCP server using LlamaCloud and how to use LlamaIndex as an MCP client.

cloud_platforms
aws-cost-explorer-mcp-server

aws-cost-explorer-mcp-server

3.6

by aarora79

An MCP server for accessing AWS spend data via Cost Explorer and Amazon Bedrock usage data through Model Invocation Logs in Amazon CloudWatch.

research_and_data
kom

kom

3.6

by weibaohui

`kom` is a tool for Kubernetes operations, providing SDK-level encapsulation of kubectl and client-go.

cloud_platforms