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

Подключение

Добавьте эту конфигурацию в .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>"
      }
    }
  }
}

Инструменты (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"
    }
  }
}

Ресурсы

Этот сервер не предоставляет ресурсы.

Промпты

Этот сервер не предоставляет промпты.

Сведения о сервере

Автор: Confluent (@confluentinc)
Репозиторий: https://github.com/confluentinc/mcp-confluent
Звёзды: 0
Последнее обновление: 12 июля 2026 г.