MCP cover image
See in Github
2025-03-17

Un serveur MCP pour Apache Kafka et son écosystème.

1

Github Watches

1

Github Forks

3

Github Stars

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

相关推荐

  • NiKole Maxwell
  • I craft unique cereal names, stories, and ridiculously cute Cereal Baby images.

  • https://suefel.com
  • Latest advice and best practices for custom GPT development.

  • Yusuf Emre Yeşilyurt
  • I find academic articles and books for research and literature reviews.

  • https://maiplestudio.com
  • Find Exhibitors, Speakers and more

  • Carlos Ferrin
  • Encuentra películas y series en plataformas de streaming.

  • Joshua Armstrong
  • Confidential guide on numerology and astrology, based of GG33 Public information

  • Contraband Interactive
  • Emulating Dr. Jordan B. Peterson's style in providing life advice and insights.

  • rustassistant.com
  • Your go-to expert in the Rust ecosystem, specializing in precise code interpretation, up-to-date crate version checking, and in-depth source code analysis. I offer accurate, context-aware insights for all your Rust programming questions.

  • Elijah Ng Shi Yi
  • Advanced software engineer GPT that excels through nailing the basics.

  • Emmet Halm
  • Converts Figma frames into front-end code for various mobile frameworks.

  • apappascs
  • Découvrez la collection la plus complète et la plus à jour de serveurs MCP sur le marché. Ce référentiel sert de centre centralisé, offrant un vaste catalogue de serveurs MCP open-source et propriétaires, avec des fonctionnalités, des liens de documentation et des contributeurs.

  • modelcontextprotocol
  • Serveurs de protocole de contexte modèle

  • Mintplex-Labs
  • L'application tout-en-un desktop et Docker AI avec chiffon intégré, agents AI, constructeur d'agent sans code, compatibilité MCP, etc.

  • ShrimpingIt
  • Manipulation basée sur Micropython I2C de l'exposition GPIO de la série MCP, dérivée d'Adafruit_MCP230XX

  • OffchainLabs
  • Aller la mise en œuvre de la preuve de la participation Ethereum

  • n8n-io
  • Plateforme d'automatisation de workflow à code équitable avec des capacités d'IA natives. Combinez le bâtiment visuel avec du code personnalisé, de l'auto-hôte ou du cloud, 400+ intégrations.

  • huahuayu
  • Une passerelle API unifiée pour intégrer plusieurs API d'explorateur de blockchain de type étherscan avec la prise en charge du protocole de contexte modèle (MCP) pour les assistants d'IA.

    Reviews

    2 (1)
    Avatar
    user_dfV12LLL
    2025-04-17

    As a dedicated user of mcp applications, I can't recommend mcp-kafka highly enough! Brandon Powers has done an excellent job creating a robust and efficient Kafka connector that’s both easy to integrate and highly reliable. The documentation on the GitHub page is thorough and user-friendly. If you're in need of a Kafka solution, this is definitely worth checking out.