Skip to content

Commit 27e2469

Browse files
authored
feat: add Confluent MCP server definition (#34)
* 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 * fix: update server definition (input type 'password' -> 'text' for CONFLUENT_CLOUD_API_KEY; input type 'password' -> 'text' for CONFLUENT_CLOUD_API_SECRET; input type 'password' -> 'text' for KAFKA_API_KEY; input type 'password' -> 'text' for KAFKA_API_SECRET) * fix: rename server files with transport suffix - io.confluent-mcp.json -> io.confluent-mcp-npx.json (id: io.confluent-mcp-npx) Signed-off-by: Mohammod Al Amin Ashik <maa.ashik00@gmail.com> --------- Signed-off-by: Mohammod Al Amin Ashik <maa.ashik00@gmail.com>
1 parent 0948bda commit 27e2469

1 file changed

Lines changed: 113 additions & 0 deletions

File tree

servers/io.confluent-mcp-npx.json

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

0 commit comments

Comments
 (0)