Skip to content

Commit ad5208c

Browse files
claudeits-mash
authored andcommitted
Add Confluent MCP server definition
Official Confluent MCP server for Kafka and streaming. Manage topics, produce/consume messages, run Flink SQL. Uses @confluentinc/mcp-confluent npm package. https://claude.ai/code/session_013AxurW8hPAfnUNvik354Xx
1 parent 0217546 commit ad5208c

1 file changed

Lines changed: 104 additions & 0 deletions

File tree

servers/io.confluent-mcp.json

Lines changed: 104 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,104 @@
1+
{
2+
"$schema": "../schemas/server-definition.schema.json",
3+
"id": "io.confluent-mcp",
4+
"name": "Confluent",
5+
"alias": "confluent",
6+
"description": "Manage Confluent Cloud and Kafka resources. Create topics, produce and consume messages, run Flink SQL queries, and manage schemas.",
7+
"icon": "https://avatars.githubusercontent.com/u/9439498?v=4",
8+
"schema_version": "2.1",
9+
"categories": ["cloud", "database"],
10+
"tags": ["confluent", "kafka", "streaming", "flink", "events", "schema-registry"],
11+
12+
"transport": {
13+
"type": "stdio",
14+
"command": "npx",
15+
"args": ["-y", "@confluentinc/mcp-confluent"],
16+
"env": {
17+
"CONFLUENT_CLOUD_API_KEY": "${input:CONFLUENT_CLOUD_API_KEY}",
18+
"CONFLUENT_CLOUD_API_SECRET": "${input:CONFLUENT_CLOUD_API_SECRET}",
19+
"BOOTSTRAP_SERVERS": "${input:BOOTSTRAP_SERVERS}",
20+
"KAFKA_API_KEY": "${input:KAFKA_API_KEY}",
21+
"KAFKA_API_SECRET": "${input:KAFKA_API_SECRET}"
22+
},
23+
"metadata": {
24+
"inputs": [
25+
{
26+
"id": "CONFLUENT_CLOUD_API_KEY",
27+
"label": "Confluent Cloud API Key",
28+
"description": "Cloud API key for Confluent Cloud resource management.",
29+
"type": "password",
30+
"required": true,
31+
"secret": true,
32+
"placeholder": "XXXXXXXXXXXXXXXX",
33+
"obtain": {
34+
"url": "https://confluent.cloud/settings/api-keys",
35+
"instructions": "1. Go to confluent.cloud > Settings > API Keys\n2. Click 'Create Key'\n3. Select 'Cloud resource management'\n4. Copy the key and secret",
36+
"button_label": "Create API Key"
37+
}
38+
},
39+
{
40+
"id": "CONFLUENT_CLOUD_API_SECRET",
41+
"label": "Confluent Cloud API Secret",
42+
"description": "Cloud API secret paired with the Cloud API key.",
43+
"type": "password",
44+
"required": true,
45+
"secret": true,
46+
"placeholder": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"
47+
},
48+
{
49+
"id": "BOOTSTRAP_SERVERS",
50+
"label": "Kafka Bootstrap Servers",
51+
"description": "Kafka bootstrap server address for your Confluent Cloud cluster.",
52+
"type": "text",
53+
"required": true,
54+
"secret": false,
55+
"placeholder": "pkc-xxxxx.us-east-1.aws.confluent.cloud:9092"
56+
},
57+
{
58+
"id": "KAFKA_API_KEY",
59+
"label": "Kafka Cluster API Key",
60+
"description": "API key specific to your Kafka cluster.",
61+
"type": "password",
62+
"required": true,
63+
"secret": true,
64+
"placeholder": "XXXXXXXXXXXXXXXX"
65+
},
66+
{
67+
"id": "KAFKA_API_SECRET",
68+
"label": "Kafka Cluster API Secret",
69+
"description": "API secret paired with the Kafka cluster API key.",
70+
"type": "password",
71+
"required": true,
72+
"secret": true,
73+
"placeholder": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"
74+
}
75+
]
76+
}
77+
},
78+
79+
"auth": {
80+
"type": "api_key",
81+
"instructions": "Create API keys at https://confluent.cloud/settings/api-keys for both Cloud and Kafka cluster access"
82+
},
83+
84+
"contributor": {
85+
"name": "Confluent",
86+
"github": "confluentinc",
87+
"url": "https://www.confluent.io"
88+
},
89+
90+
"links": {
91+
"repository": "https://github.com/confluentinc/mcp-confluent",
92+
"homepage": "https://www.confluent.io",
93+
"documentation": "https://docs.confluent.io"
94+
},
95+
96+
"platforms": ["all"],
97+
98+
"capabilities": {
99+
"tools": true,
100+
"resources": false,
101+
"prompts": false,
102+
"read_only_mode": false
103+
}
104+
}

0 commit comments

Comments
 (0)