================== /// MCP /// /// MCP /// ================== [server:online] [protocol:ready]
mcp-confluent
by confluentinc
Node/TypeScript implementation of a Model-Context-Protocol (MCP) server that lets AI assistants manage Confluent Cloud resources (Kafka, Connect, Flink, Tableflow, Schema Registry) through natural-language tools.
85
26
EnterpriseInstallation
1. Prerequisites
• Node.js ≥ 18
• npm (comes with Node) or yarn
• Confluent Cloud or self-managed Kafka cluster credentials (bootstrap-servers, API key/secret)
2. Clone the repository
git clone https://github.com/confluentinc/mcp-confluent.git
cd mcp-confluent
3. Install dependencies
npm install # or: yarn install
4. Build TypeScript → JavaScript
npm run build # invokes tsc
5. Configure environment
export KAFKA_BOOTSTRAP_SERVERS="<broker>:9092"
export KAFKA_API_KEY="<key>"
export KAFKA_API_SECRET="<secret>"
# Optional MCP settings
export MCP_PORT=8080
export MCP_LOG_LEVEL=info
6. Start the MCP server
npm start # or: node dist/index.js
7. Verify
curl http://localhost:8080/healthz
8. Docker (optional)
docker build -t mcp-confluent .
docker run -e KAFKA_BOOTSTRAP_SERVERS=... -e KAFKA_API_KEY=... -e KAFKA_API_SECRET=... -p 8080:8080 mcp-confluent
Documentation
License: MIT License
Updated 7/30/2025