mcp-kafka

Apache Kafka용 Model Context Protocol 서버입니다. MCP 호환 클라이언트(Claude Desktop, Claude Code 등)가 Kafka 클러스터의 주제, 파티션, 설정, 소비자 그룹(지연 포함)을 모니터링하고 관리할 수 있게 해 주며, 동작은 전적으로 플래그로 제어됩니다.

기본적으로 안전합니다. 읽기 전용으로 시작하며, 주제 허용 목록(allowlist)으로 범위를 제한할 수 있고, 내부/중요한 주제는 변경으로부터 보호하며, 파괴적인 작업은 명시적 동의(opt-in)를 거쳐야 수행됩니다.

기능

• 모니터링 — 클러스터/브로커 정보, 주제 메타데이터 및 오프셋, 소비자 그룹, 파티션별 + 전체 소비자 지연(lag).

• 관리 — 주제 생성, 파티션 추가, 주제 설정 변경, 그룹 오프셋 리셋, 주제/그룹 삭제(관리자).

• 액세스 모드 — read-only → read-write → admin으로 계층화되어 있어, 특정 모드는 그 수준보다 상위 도구를 노출하지 않습니다.

• 보안 플래그 — 주제 허용 목록, 보호/내부 주제, 삭제 게이팅(gating), 드라이런(dry-run), JSON 감사 로깅(아래 참조).

• 인증 — 일반 텍스트, TLS, SASL(PLAIN / SCRAM-SHA-256 / SCRAM-SHA-512).

Related MCP server: Kafka MCP Server

보안 모델

도구

읽기(read-only+): cluster_info, list_topics, describe_topic, topic_offsets, list_consumer_groups, describe_consumer_group(지연 포함)

쓰기(read-write+): create_topic, create_partitions, alter_topic_config, reset_consumer_group_offsets

관리자(admin): delete_topic, delete_consumer_group(둘 다 KAFKA_ALLOW_DELETE 필요)

MCP 클라이언트와 함께 사용

Claude Code, Claude Desktop, Cursor, OpenAI Codex CLI, Windsurf, VS Code(Copilot) 및 기타 모든 MCP 클라이언트에서 작동합니다. 클라이언트별 설정은 **docs/CLIENTS.md**를 참조하세요.

설치

npm install
npm run build

Claude Desktop / Claude Code에서 실행

{
  "mcpServers": {
    "kafka": {
      "command": "node",
      "args": ["/absolute/path/to/mcp-kafka/dist/index.js"],
      "env": {
        "KAFKA_BROKERS": "broker1:9092,broker2:9092",
        "KAFKA_MODE": "read-only",
        "KAFKA_SSL": "true",
        "KAFKA_SASL_MECHANISM": "scram-sha-512",
        "KAFKA_SASL_USERNAME": "mcp",
        "KAFKA_SASL_PASSWORD": "…"
      }
    }
  }
}

예제 프롬프트

• "지금 가장 지연이 큰 소비자 아웃 그룹은 무엇인가요?"

• "orders 주제를 설명하고 해당 오프셋을 보여 주세요."

• "events 주제를 6개 파티션과 7일 보존 기간으로 생성하세요."(read-write 필요)

개발

npm run dev
npm test
npm run typecheck

게시

이 서버는 공식 MCP 레지스트리용 server.json과 npm 소유권 검증용 mcpName을 함께 제공합니다. npm에 게시하고 MCP 레지스트리, Smithery, Glama, Cursor, PulseMCP에 등록하는 방법은 **PUBLISHING.md**를 참조하세요.

라이선스

MIT