Skip to main content
Glama
73,458 servers. Updated

Matching MCP tools:

Matching MCP Connectors:

"Apache Kafka" matching MCP servers:

  • A
    license
    A
    quality
    D
    maintenance
    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.
    42
    1
    Apache 2.0
  • A
    license
    B
    quality
    C
    maintenance
    MCP server for Apache Kafka that allows LLM agents to inspect topics, consumer groups, and safely manage offsets (reset, rewind).
    16
    12
    Apache 2.0
  • F
    license
    B
    quality
    D
    maintenance
    Enables interaction with Apache Kafka clusters, allowing management of topics, message production, and consumption through natural language.
    5
  • A
    license
    C
    quality
    B
    maintenance
    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.
    11
    2
    Apache 2.0
  • A
    license
    -
    quality
    C
    maintenance
    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.
    1
    MIT
  • A
    license
    -
    quality
    D
    maintenance
    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.
    17
    Apache 2.0
  • A
    license
    -
    quality
    D
    maintenance
    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.
    MIT
  • A
    license
    A
    quality
    B
    maintenance
    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.
    3
    Apache 2.0
  • A
    license
    A
    quality
    A
    maintenance
    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.
    16
    2
    Apache 2.0
  • A
    license
    A
    quality
    C
    maintenance
    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.
    16
    MIT
  • A
    license
    A
    quality
    D
    maintenance
    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.
    4
    MIT
  • A
    license
    A
    quality
    B
    maintenance
    Official MCP server for Apache Drill, enabling read-only SQL queries and inspection of schemas, storage plugins, and cluster/query state.
    9
    Apache 2.0
  • A
    license
    A
    quality
    D
    maintenance
    An MCP server that enables users to interact with Apache Doris databases through natural language, supporting query and management operations.
    3
    Apache 2.0
  • A
    license
    A
    quality
    D
    maintenance
    An MCP server for querying and analyzing Apache Incubator podling health reports. It provides tools to list, search, and compare podling metrics across different time windows from Apache's health report Markdown files.
    9
    MIT
  • A
    license
    B
    quality
    A
    maintenance
    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.
    8
    2
    MIT