Confluent MCP Server

DevOpsstdio

Confluent's open-source MCP server that connects AI assistants to Confluent Cloud, Confluent Platform, and standalone Apache Kafka deployments. Provides tools to manage Kafka topics and connectors, work with Schema Registry, and run Flink SQL statements through natural language, helping teams operate streaming data platforms from an MCP client.

confluent kafka streaming flink schema-registry devops

Connect

Add this configuration to .claude/mcp.json

{
  "mcpServers": {
    "confluent": {
      "command": "npx",
      "args": [
        "-y",
        "@confluentinc/mcp-confluent",
        "-e",
        ".env"
      ],
      "env": {
        "BOOTSTRAP_SERVERS": "<YOUR_BOOTSTRAP_SERVERS>",
        "KAFKA_API_KEY": "<YOUR_KAFKA_API_KEY>",
        "KAFKA_API_SECRET": "<YOUR_KAFKA_API_SECRET>"
      }
    }
  }
}

Tools (3)

list_topics

List Kafka topics in the connected Confluent or Kafka cluster.

{
  "type": "object",
  "properties": {}
}

create_topic

Create a new Kafka topic with the given partitions and configuration.

{
  "type": "object",
  "required": [
    "topic_name"
  ],
  "properties": {
    "partitions": {
      "type": "integer",
      "description": "Number of partitions"
    },
    "topic_name": {
      "type": "string",
      "description": "Name of the topic to create"
    }
  }
}

produce_message

Produce a message to a Kafka topic.

{
  "type": "object",
  "required": [
    "topic_name",
    "value"
  ],
  "properties": {
    "value": {
      "type": "string",
      "description": "Message payload"
    },
    "topic_name": {
      "type": "string",
      "description": "Target topic"
    }
  }
}

Resources

This server does not expose any resources.

Prompts

This server does not expose any prompts.

Server Information

Author: Confluent (@confluentinc)
Repository: https://github.com/confluentinc/mcp-confluent
Stars: 0
Last Updated: July 12, 2026