Oci Kafka MCP Server

OCI Kafka MCP服务器

AI原生控制界面 使用Apache Kafka进行OCI流式传输，建立在 模型上下文协议（MCP） 规范。

此MCP服务器使LLM代理（Claude、GPT等）能够通过结构化工具执行安全地管理Kafka集群，并具有内置的安全防护、审计日志和企业级安全性。

特性

• 42种结构化工具 用于集群、主题、消费者、可观察性、人工智能诊断、OCI元数据、集群生命周期、集群配置和工作请求操作
• 默认情况下为只读 --编写工具需要明确 --allow-writes 旗帜
• 政策保护 --每个工具都进行了风险分类（低/中/高）；破坏性操作需要确认
• AI诊断工具 --编排多个Kafka操作以生成缩放建议和滞后根本原因分析
• 断路器 --防止Kafka不可用时发生级联故障
• 结构化审计日志记录 --每个工具执行都以JSON格式记录，并带有时间戳、输入哈希和持续时间
• SASL/SCRAM-SHA-512+TLS --企业安全从第一天开始
• 专用网络 --专为OCI专用端点设计

快速开始

先决条件

• Python 3.11+
• 紫外线 （推荐）或pip

安装

git clone 
cd oci-kafka-mcp-server
uv sync

使用本地Kafka运行（开发，Podman）

# Start a local Kafka broker
podman compose -f docker/docker-compose.yaml up -d

# Run the MCP server (read-only mode)
uv run oci-kafka-mcp

# Run with write tools enabled
uv run oci-kafka-mcp --allow-writes

# Stop local Kafka
podman compose -f docker/docker-compose.yaml down

配置OCI流

您可以通过以下任一方式配置OCI Kafka：

1. 预先设置环境变量 （可选）
2. 不设置变量 并让MCP服务器在运行时请求所需的值，然后调用 oci_kafka_configure_connection

如果要预先配置环境变量：

export KAFKA_BOOTSTRAP_SERVERS="bootstrap-clstr-XXXXX.kafka.us-chicago-1.oci.oraclecloud.com:9092"
export KAFKA_SECURITY_PROTOCOL="SASL_SSL"
export KAFKA_SASL_MECHANISM="SCRAM-SHA-512"
export KAFKA_SASL_USERNAME="your-username"
export KAFKA_SASL_PASSWORD="your-password"
export KAFKA_SSL_CA_LOCATION="/path/to/ca.pem"

uv run oci-kafka-mcp

或者使用OCI模板文件：

cp .env.oci.example .env.oci
# edit .env.oci with your cluster values
source .env.oci
uv run oci-kafka-mcp

注： KAFKA_* 变量是 非强制性 在服务器启动时。如果未设置，工具将指导代理/用户提供连接详细信息和使用 oci_kafka_configure_connection 在数据平面操作之前。

与MCP客户端一起使用

这 env 下面的块是可选的——如果省略，服务器将提示代理调用 oci_kafka_configure_connection 在运行时显示集群详细信息。

Cline（VS代码扩展）

添加到您的Cline MCP设置中：

{
  "mcpServers": {
    "oci-kafka": {
      "type": "stdio",
      "command": "/path/to/oci-kafka-mcp-server/.venv/bin/oci-kafka-mcp",
      "args": ["--allow-writes"],
      "env": {
        "KAFKA_BOOTSTRAP_SERVERS": "your-bootstrap:9092",
        "KAFKA_SECURITY_PROTOCOL": "SASL_SSL",
        "KAFKA_SASL_MECHANISM": "SCRAM-SHA-512",
        "KAFKA_SASL_USERNAME": "your-username",
        "KAFKA_SASL_PASSWORD": "your-password"
      }
    }
  }
}

光标

增添 .cursor/mcp.json （项目层面）或 ~/.cursor/mcp.json （全球）：

{
  "mcpServers": {
    "oci-kafka": {
      "type": "stdio",
      "command": "/path/to/oci-kafka-mcp-server/.venv/bin/oci-kafka-mcp",
      "args": ["--allow-writes"],
      "env": {
        "KAFKA_BOOTSTRAP_SERVERS": "your-bootstrap:9092",
        "KAFKA_SECURITY_PROTOCOL": "SASL_SSL",
        "KAFKA_SASL_MECHANISM": "SCRAM-SHA-512",
        "KAFKA_SASL_USERNAME": "your-username",
        "KAFKA_SASL_PASSWORD": "your-password"
      }
    }
  }
}

MCP主机

添加到MCPHost配置文件中（例如。， ~/.mcphost.json):

{
  "mcpServers": {
    "oci-kafka": {
      "type": "stdio",
      "command": "/path/to/oci-kafka-mcp-server/.venv/bin/oci-kafka-mcp",
      "args": ["--allow-writes"],
      "env": {
        "KAFKA_BOOTSTRAP_SERVERS": "your-bootstrap:9092",
        "KAFKA_SECURITY_PROTOCOL": "SASL_SSL",
        "KAFKA_SASL_MECHANISM": "SCRAM-SHA-512",
        "KAFKA_SASL_USERNAME": "your-username",
        "KAFKA_SASL_PASSWORD": "your-password"
      }
    }
  }
}

然后使用以下命令启动MCPHost：

mcphost -m ollama: --config ~/.mcphost.json

可用工具（42）

连接管理

集群操作

主题操作

消费者操作

可观测性

AI诊断

OCI控制平面元数据

集群生命周期（OCI控制平面）

异步操作——返回工作请求OCID；使用 oci_kafka_get_work_request 投票以完成。

集群配置（OCI控制平面）

命名的、版本化的Kafka代理设置集，可以应用于一个或多个集群。

工作请求和节点形状（OCI控制平面）

跟踪集群生命周期和配置工具返回的异步OCI操作。

安全模型

发展

# Run tests (92 tests, all unit — no Kafka broker needed)
uv run pytest

# Run tests with coverage
uv run pytest --cov=oci_kafka_mcp --cov-report=term-missing

# Lint
uv run ruff check src/ tests/

# Format
uv run ruff format src/ tests/

# Type check
uv run mypy src/

建筑

看 docs/ARCHITECTURE.md 完整的安全架构文档，包括威胁模型、依赖性审计和部署架构。

许可证

阿帕奇-2.0