From 294f3a2b103c9e51b212de9a22ca291b66f45c4d Mon Sep 17 00:00:00 2001 From: Mohammod Al Amin Ashik Date: Wed, 11 Feb 2026 13:21:32 +0000 Subject: [PATCH 1/3] 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 --- servers/io.confluent-mcp.json | 104 ++++++++++++++++++++++++++++++++++ 1 file changed, 104 insertions(+) create mode 100644 servers/io.confluent-mcp.json diff --git a/servers/io.confluent-mcp.json b/servers/io.confluent-mcp.json new file mode 100644 index 0000000..b72f166 --- /dev/null +++ b/servers/io.confluent-mcp.json @@ -0,0 +1,104 @@ +{ + "$schema": "../schemas/server-definition.schema.json", + "id": "io.confluent-mcp", + "name": "Confluent", + "alias": "confluent", + "description": "Manage Confluent Cloud and Kafka resources. Create topics, produce and consume messages, run Flink SQL queries, and manage schemas.", + "icon": "https://avatars.githubusercontent.com/u/9439498?v=4", + "schema_version": "2.1", + "categories": ["cloud", "database"], + "tags": ["confluent", "kafka", "streaming", "flink", "events", "schema-registry"], + + "transport": { + "type": "stdio", + "command": "npx", + "args": ["-y", "@confluentinc/mcp-confluent"], + "env": { + "CONFLUENT_CLOUD_API_KEY": "${input:CONFLUENT_CLOUD_API_KEY}", + "CONFLUENT_CLOUD_API_SECRET": "${input:CONFLUENT_CLOUD_API_SECRET}", + "BOOTSTRAP_SERVERS": "${input:BOOTSTRAP_SERVERS}", + "KAFKA_API_KEY": "${input:KAFKA_API_KEY}", + "KAFKA_API_SECRET": "${input:KAFKA_API_SECRET}" + }, + "metadata": { + "inputs": [ + { + "id": "CONFLUENT_CLOUD_API_KEY", + "label": "Confluent Cloud API Key", + "description": "Cloud API key for Confluent Cloud resource management.", + "type": "password", + "required": true, + "secret": true, + "placeholder": "XXXXXXXXXXXXXXXX", + "obtain": { + "url": "https://confluent.cloud/settings/api-keys", + "instructions": "1. Go to confluent.cloud > Settings > API Keys\n2. Click 'Create Key'\n3. Select 'Cloud resource management'\n4. Copy the key and secret", + "button_label": "Create API Key" + } + }, + { + "id": "CONFLUENT_CLOUD_API_SECRET", + "label": "Confluent Cloud API Secret", + "description": "Cloud API secret paired with the Cloud API key.", + "type": "password", + "required": true, + "secret": true, + "placeholder": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx" + }, + { + "id": "BOOTSTRAP_SERVERS", + "label": "Kafka Bootstrap Servers", + "description": "Kafka bootstrap server address for your Confluent Cloud cluster.", + "type": "text", + "required": true, + "secret": false, + "placeholder": "pkc-xxxxx.us-east-1.aws.confluent.cloud:9092" + }, + { + "id": "KAFKA_API_KEY", + "label": "Kafka Cluster API Key", + "description": "API key specific to your Kafka cluster.", + "type": "password", + "required": true, + "secret": true, + "placeholder": "XXXXXXXXXXXXXXXX" + }, + { + "id": "KAFKA_API_SECRET", + "label": "Kafka Cluster API Secret", + "description": "API secret paired with the Kafka cluster API key.", + "type": "password", + "required": true, + "secret": true, + "placeholder": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx" + } + ] + } + }, + + "auth": { + "type": "api_key", + "instructions": "Create API keys at https://confluent.cloud/settings/api-keys for both Cloud and Kafka cluster access" + }, + + "contributor": { + "name": "Confluent", + "github": "confluentinc", + "url": "https://www.confluent.io" + }, + + "links": { + "repository": "https://github.com/confluentinc/mcp-confluent", + "homepage": "https://www.confluent.io", + "documentation": "https://docs.confluent.io" + }, + + "platforms": ["all"], + + "capabilities": { + "tools": true, + "resources": false, + "prompts": false, + "read_only_mode": false + } +} From 556f8d92166460672434b6b163b03902c704cb02 Mon Sep 17 00:00:00 2001 From: Mohammod Al Amin Ashik Date: Thu, 19 Feb 2026 19:08:45 +0800 Subject: [PATCH 2/3] 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) --- servers/io.confluent-mcp.json | 37 ++++++++++++++++++++++------------- 1 file changed, 23 insertions(+), 14 deletions(-) diff --git a/servers/io.confluent-mcp.json b/servers/io.confluent-mcp.json index b72f166..63b5ab3 100644 --- a/servers/io.confluent-mcp.json +++ b/servers/io.confluent-mcp.json @@ -6,13 +6,25 @@ "description": "Manage Confluent Cloud and Kafka resources. Create topics, produce and consume messages, run Flink SQL queries, and manage schemas.", "icon": "https://avatars.githubusercontent.com/u/9439498?v=4", "schema_version": "2.1", - "categories": ["cloud", "database"], - "tags": ["confluent", "kafka", "streaming", "flink", "events", "schema-registry"], - + "categories": [ + "cloud", + "database" + ], + "tags": [ + "confluent", + "kafka", + "streaming", + "flink", + "events", + "schema-registry" + ], "transport": { "type": "stdio", "command": "npx", - "args": ["-y", "@confluentinc/mcp-confluent"], + "args": [ + "-y", + "@confluentinc/mcp-confluent" + ], "env": { "CONFLUENT_CLOUD_API_KEY": "${input:CONFLUENT_CLOUD_API_KEY}", "CONFLUENT_CLOUD_API_SECRET": "${input:CONFLUENT_CLOUD_API_SECRET}", @@ -26,7 +38,7 @@ "id": "CONFLUENT_CLOUD_API_KEY", "label": "Confluent Cloud API Key", "description": "Cloud API key for Confluent Cloud resource management.", - "type": "password", + "type": "text", "required": true, "secret": true, "placeholder": "XXXXXXXXXXXXXXXX", @@ -40,7 +52,7 @@ "id": "CONFLUENT_CLOUD_API_SECRET", "label": "Confluent Cloud API Secret", "description": "Cloud API secret paired with the Cloud API key.", - "type": "password", + "type": "text", "required": true, "secret": true, "placeholder": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx" @@ -58,7 +70,7 @@ "id": "KAFKA_API_KEY", "label": "Kafka Cluster API Key", "description": "API key specific to your Kafka cluster.", - "type": "password", + "type": "text", "required": true, "secret": true, "placeholder": "XXXXXXXXXXXXXXXX" @@ -67,7 +79,7 @@ "id": "KAFKA_API_SECRET", "label": "Kafka Cluster API Secret", "description": "API secret paired with the Kafka cluster API key.", - "type": "password", + "type": "text", "required": true, "secret": true, "placeholder": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx" @@ -75,26 +87,23 @@ ] } }, - "auth": { "type": "api_key", "instructions": "Create API keys at https://confluent.cloud/settings/api-keys for both Cloud and Kafka cluster access" }, - "contributor": { "name": "Confluent", "github": "confluentinc", "url": "https://www.confluent.io" }, - "links": { "repository": "https://github.com/confluentinc/mcp-confluent", "homepage": "https://www.confluent.io", "documentation": "https://docs.confluent.io" }, - - "platforms": ["all"], - + "platforms": [ + "all" + ], "capabilities": { "tools": true, "resources": false, From cb86883bfb70b5e44f84302313c85101381c199c Mon Sep 17 00:00:00 2001 From: Mohammod Al Amin Ashik Date: Thu, 19 Feb 2026 22:44:11 +0800 Subject: [PATCH 3/3] 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 --- servers/{io.confluent-mcp.json => io.confluent-mcp-npx.json} | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) rename servers/{io.confluent-mcp.json => io.confluent-mcp-npx.json} (98%) diff --git a/servers/io.confluent-mcp.json b/servers/io.confluent-mcp-npx.json similarity index 98% rename from servers/io.confluent-mcp.json rename to servers/io.confluent-mcp-npx.json index 63b5ab3..2ce53d7 100644 --- a/servers/io.confluent-mcp.json +++ b/servers/io.confluent-mcp-npx.json @@ -1,7 +1,7 @@ { "$schema": "../schemas/server-definition.schema.json", - "id": "io.confluent-mcp", - "name": "Confluent", + "id": "io.confluent-mcp-npx", + "name": "Confluent (npx)", "alias": "confluent", "description": "Manage Confluent Cloud and Kafka resources. Create topics, produce and consume messages, run Flink SQL queries, and manage schemas.", "icon": "https://avatars.githubusercontent.com/u/9439498?v=4",