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

Bağlan

Bu yapılandırmayı şuraya ekleyin: .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>"
      }
    }
  }
}

Araçlar (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"
    }
  }
}

Kaynaklar

Bu sunucu herhangi bir kaynak sunmuyor.

Prompt'lar

Bu sunucu herhangi bir prompt sunmuyor.

Sunucu bilgileri

Yazar: Confluent (@confluentinc)
Repository: https://github.com/confluentinc/mcp-confluent
Yıldızlar: 0
Son güncelleme: 12 Temmuz 2026