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
最后更新: 2026年7月12日