mcp-registry/mcp-confluent

    ==================
      
       /// 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
Enterprise
GitHub

Installation

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