mcp-kafka
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.
mcp-kafka is a server-side implementation of the Model Context Protocol (MCP) designed for Apache Kafka. It facilitates reliable interactions between language models and the Kafka ecosystem, including Kafka Connect, Burrow, and Cruise Control. The server supports core Kafka APIs, excluding Streams, and provides REST API support for Burrow and Cruise Control. The project is a work in progress, with ongoing development to enhance features such as asyncio and aiohttp integration, environment configuration, and comprehensive API support. Future plans include publishing to PyPI, Docker integration, and potential Strimzi/kcctl integrations.
Features
- Supports core Kafka APIs excluding Streams.
- Provides REST API support for Burrow and Cruise Control.
- Planned integration with asyncio and aiohttp.
- Environment configuration through data classes.
- Future publishing to PyPI and Docker integration.
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
