"Apache Kafka" matching MCP servers:

Enables large language models and AI agents to securely and efficiently interact with Apache Kafka clusters through the Model Context Protocol.

Reference implementation of KIP-1318, a secure Model Context Protocol server for Apache Kafka that enables AI agents to interact with Kafka clusters through governed tools and resources.

Manage Apache Kafka on Kubernetes via Strimzi. Clusters, topics, users, connectors, MirrorMaker2, and node pools.

A comprehensive MCP server for Apache Kafka operations, enabling seamless integration with Claude Desktop and other MCP clients for cluster management, topic operations, and message streaming.

MCP server that exposes Kafka debugging to an LLM: find messages, measure lag, unblock consumers. Read-only endpoints, previews before writes.

A DataOps-focused Kafka MCP server with consumer lag diagnosis and broker health monitoring, featuring incident-based diagnosis logic derived from real CDC pipeline operational experience.

Enables MCP-capable clients to monitor and manage Apache Kafka clusters, including topics, partitions, configs, and consumer groups with lag, while enforcing configurable security modes, topic allowlists, protected topics, and audit logging.

Enables AI assistants to interact with Apache Kafka clusters through AKHQ's REST API. Supports multi-environment configuration, flexible authentication, and comprehensive coverage of topics, consumer groups, schema registry, Kafka Connect, ksqlDB, and ACLs.

Provides a standardized way for MCP clients to interact with Apache Airflow's REST API, supporting operations like DAG management and monitoring Airflow system health.

Exposes Kafka administration operations as MCP tools, enabling AI agents to inspect Kafka clusters using natural language.

Integration with Timeplus, a database for streaming data, such as Apache Kafka/Pulsar

This read-only MCP server lets AI assistants inspect Apache NiFi, ClickHouse, and Kafka across multiple environments through natural language. It provides health checks, flow and message searches, querying and metadata tools while enforcing OIDC or proxy authentication, per-user auditing, secret masking, and two-lock read-only safeguards.

Enables Claude Code to generate Kafka producer and consumer code using predefined event schemas, with tools to list events, get schemas, and validate code.

An MCP server that enables AI assistants to safely interact with Apache Kafka clusters, providing tools for topic management, message operations, consumer groups, and cluster information.

Enables interaction with Kafka clusters via MCP, supporting topic management (list, create, delete, inspect), connection initialization, and more through natural language.

Enables AI agents to interact with Apache Kafka through natural language, supporting operations like producing/consuming messages, managing topics, and querying brokers, partitions, and consumer group offsets.

Enables LLM agents to interact with Apache Zeppelin notebooks via the Zeppelin REST API, supporting operations like listing, searching, editing, and running notebooks.

Enables interaction with Apache Airflow through the Model Context Protocol, allowing users to manage DAGs, task instances, variables, connections, pools, XComs, and datasets.

An MCP server that enables interaction with Kafka clusters to manage topics, monitor consumer groups, and stream messages. It provides a comprehensive suite of tools for broker metadata inspection and local Kafka user management.

MCP server that diagnoses Apache Spark job failures and optimizes performance using stack-trace analysis and LLM providers, supporting EMR and local sources.