"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 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.

A comprehensive Message Control Protocol (MCP) server for Kafka Schema Registry.

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.

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.

Enables LLM agents to query Apache Hive/HiveServer2 by listing tables and running read-only SQL, with results returned as JSON.

Official MCP server for Apache Drill, enabling read-only SQL queries and inspection of schemas, storage plugins, and cluster/query state.

An MCP server that enables users to interact with Apache Doris databases through natural language, supporting query and management operations.

Enables AI assistants to read and search Kafka messages through the Redpanda Console HTTP API, including topic listing, message fetching by offset or time, and substring search, without direct Kafka broker access.

Read-only MCP server for Kafka cluster health, consumer lag, partition state, and replay-readiness, enabling AI agents to diagnose streaming incidents without write access.

A Model Context Protocol server that provides seamless access to multiple storage services including S3, Azure Blob Storage, and Google Cloud Storage through Apache OpenDAL™.

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

A read-only kubectl MCP server for AI assistants. The kubectl verb is hardcoded in each tool (get/describe/logs/events) and user input only fills argument values — no mutation path even with malicious input, and Secret/ConfigMap values are never returned (metadata only). Returns structured JSON, plus one-shot k8s_triage (health scan) and k8s_inventory (cluster snapshot).