OfficialVerified

Confluent MCP Server

Kafka, Flink SQL, and Schema Registry operations for AI-driven data pipelines.

Data last scanned today · Reviewed today

45 6 dangerous tools73 tools★ 167TypeScriptMIT

Overview

The Confluent MCP Server facilitates direct interaction with Confluent Cloud, Confluent Platform, and self-managed Apache Kafka environments. It exposes over 50 tools to AI assistants, enabling tasks spanning message streaming, SQL queries via Flink, and schema management. Designed for flexibility, it supports both cloud-managed and local infrastructure setups. Users can customize their integration by enabling specific service blocks, making it a robust choice for developers who require local control over their Kafka-related AI workflows.

Our verdict

With a security score of 42/100, this server is currently classified as high-risk. This rating reflects the fact that it is a community-maintained project rather than an official vendor-supported tool, and critical security aspects—specifically the authentication methods and read-only mode capabilities—have not yet undergone an editorial review. It is best suited for experienced developers working in self-managed Kafka environments who can independently audit the source code and configuration.

Supports 50+ diverse Kafka and Flink SQL tools
Open-source TypeScript implementation under MIT license
Maintains an active development cycle with recent commits
Includes 31 contributors to support ongoing project health

Community-supported with no service level commitments
Authentication and read-only modes remain unreviewed
Requires manual setup and management of local configuration

Setup

Claude Desktop

{
  "mcpServers": {
    "mcp-confluent": {
      "args": [
        "-y",
        "@confluentinc/mcp-confluent"
      ],
      "command": "npx"
    }
  }
}

Paste into ~/Library/Application Support/Claude/claude_desktop_config.json (macOS) or %APPDATA%\Claude\claude_desktop_config.json (Windows), then restart Claude Desktop. Some servers require API keys or tokens as environment variables — check the project's README and add an "env" object if needed.

No read-only mode — running this grants full read/write access.
No built-in authentication — anyone with access to this config can invoke every tool it exposes.

Tools

Tool	Description	Risk
search-product-docs	Search Confluent product docs and fetch full page content	low
get-product-doc-page	Search Confluent product docs and fetch full page content	low
explain-disabled-tools	Explain why tools are absent, list configured connections and the tools enabled on each, suggest the YAML to enable a specific tool, and describe one connection's config and tool availability	low
list-configured-connections	Explain why tools are absent, list configured connections and the tools enabled on each, suggest the YAML to enable a specific tool, and describe one connection's config and tool availability	low
config-help	Explain why tools are absent, list configured connections and the tools enabled on each, suggest the YAML to enable a specific tool, and describe one connection's config and tool availability	low
describe-configured-connection	Explain why tools are absent, list configured connections and the tools enabled on each, suggest the YAML to enable a specific tool, and describe one connection's config and tool availability	low
list-topics	Manage topics, produce/consume messages, inspect consumer groups, configure topic settings	low
create-topics	Manage topics, produce/consume messages, inspect consumer groups, configure topic settings	medium
delete-topics	Manage topics, produce/consume messages, inspect consumer groups, configure topic settings	high
produce-message	Manage topics, produce/consume messages, inspect consumer groups, configure topic settings	medium

Compatibility

Client	Local	Docker	Remote	Read-only
Claude Desktop
Cursor
VS Code
Windsurf
ChatGPT

Frequently asked questions

›What are the system prerequisites for running this MCP server?

You must have Node.js version 22.19.0 or higher installed on your machine.

›How do I determine which tools are enabled for my current configuration?

You can use the command 'npx -y @confluentinc/mcp-confluent --list-tools' to see all available tools, or use the 'explain-disabled-tools' diagnostic tool to understand why certain tools are unavailable.

›Should I use the open-source server or the managed version?

The open-source server is recommended if you need to support Confluent Platform, self-managed Kafka deployments, or require custom tool extensions. If you are a Confluent Cloud customer, you may prefer the fully managed MCP server which requires no local installation.

›Is there dedicated support for this open-source MCP server?

No, this is a community-supported project. Support is provided on a best-effort basis without service level commitments, and issues should be reported via GitHub pull requests or issues.

›Can I use OAuth authentication instead of API keys for Confluent Cloud?

Yes, specific categories of tools support OAuth authentication, allowing you to sign in via your browser instead of provisioning API keys.