"Apache Kafka" matching MCP servers:

An AI-native control interface for OCI Streaming with Apache Kafka that enables LLM agents to securely manage Kafka clusters through structured tool execution with safety guardrails.

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 large language models and AI agents to securely and efficiently interact with Apache Kafka clusters through the Model Context Protocol.

MCP server for Apache Kafka that allows LLM agents to inspect topics, consumer groups, and safely manage offsets (reset, rewind).

Enables interaction with Apache Kafka clusters, allowing management of topics, message production, and consumption through natural language.

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

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.

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 AI models to publish and consume messages from Apache Kafka topics through a standardized interface, making it easy to integrate Kafka messaging with LLM and agent applications.

An MCP server that gives AI agents real-time observability into Apache Kafka clusters, enabling natural language queries for broker health, consumer lag, and diagnostics.

Enables interaction with Apache Kafka topics, allowing users to publish messages to and read messages from Kafka instances through natural language.

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.

A tool that converts natural-language requests into full, deployable, execution-verified Apache Flink SQL jobs by orchestrating an LLM to draft specs, generate Flink SQL, and verify correctness against real Flink clusters and streaming semantics—including windowed aggregates, joins, Kafka grounding, and Deployable pipelines via the generate_flink_job, ground_kafka_topic, and deploy_to_kafka tools.

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

Enables inspection and management of Apache Airflow DAGs, runs, and logs across multiple instances. It provides tools for monitoring workflows and performing gated write operations like triggering DAGs or clearing task instances.

Enables querying and managing Apache Druid datasources through natural language, including SQL queries, datasource exploration, and cluster connectivity testing.

Connects LLM agents to Apache Atlas for searching, tracing lineage, and managing metadata. Read-only by default, with optional write mode for creating entities and classifications.

Enables lookups across Apache Iceberg Javadocs, local source evidence, and Iceberg REST Catalog operations through MCP tools and prompts.

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.