mcp-confluent

Name: mcp-confluent
Author: confluentinc

@confluentinc

Repository

About mcp-confluent

No overview available yet

Basic information

Config

Add this server to your MCP-compatible client using the configuration below.

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

Tools

No tools detected

We auto-extract tools from the README. The maintainer can list them under a ## Tools heading to populate this section.

Overview

What is mcp-confluent?

An open-source MCP server that enables AI assistants to interact with Confluent Cloud, Confluent Platform, and standalone Apache Kafka deployments through natural language. It provides 50+ tools across Kafka, Flink SQL, Schema Registry, Connectors, Tableflow, and more, usable from any MCP-compatible client.

How to use mcp-confluent?

Install prerequisites (Node.js 22.19.0+) and optionally create a Confluent Cloud account. Generate a config.yaml with npx @confluentinc/mcp-confluent --init-config, edit it with connection details, then run npx @confluentinc/mcp-confluent --config ./config.yaml. Configure your MCP client to point to the server.

Key features of mcp-confluent

50+ tools across Kafka, Flink SQL, Schema Registry, Connectors, Tableflow, and more.
Always-available tools for documentation and diagnostics.
Tools for Confluent Cloud with OAuth authentication support.
Tools for local deployments (Confluent Platform / self-managed Kafka).
Tools auto-enabled based on configuration service blocks.
Works with Claude Desktop, Claude Code, Cursor, VS Code, Goose, Gemini CLI.

Use cases of mcp-confluent

Manage Kafka topics, produce/consume messages, and inspect consumer groups via natural language.
Create and manage Flink SQL statements, explore Flink catalogs, and diagnose query issues.
Inspect and manage Kafka Connect connectors, view logs, and get error recommendations.
Discover Confluent Cloud resources: organizations, environments, and clusters.
Query billing costs and operational metrics from Confluent Cloud.

FAQ from mcp-confluent

What are the runtime requirements?

Node.js 22.19.0+ is required. For Confluent Cloud integration, a Confluent Cloud account is needed.

Can I use OAuth instead of API keys?

Yes, for many Confluent Cloud tools OAuth authentication is supported – sign in via your browser instead of provisioning static API keys. Some tools currently still require a direct connection with static keys.

Is there a managed alternative?

Yes, Confluent offers a fully managed MCP server with no local server to run. The open-source server is recommended for Confluent Platform / self-managed Kafka support or if you want to customize the toolset.