mcp-debezium
mcp-debezium
Model Context Protocol 서버로, Debezium(Kafka Connect REST API 경유)용입니다. MCP 지원 클라이언트(Claude Desktop, Claude Code 등)에서 CDC(변경 데이터 캡처) 커넥터를 모니터링하고 관리할 수 있습니다. 상태, 구성, 재시작, 수명 주기 — 모든 동작은 전적으로 플래그에 의해 제어됩니다.
기본적으로 안전하게 동작합니다. 읽기 전용으로 시작하며, 커넥터 허용 목록으로 범위를 제한할 수 있고, 중요 커넥터를 변경·삭제로부터 보호하며, 커넥터 구성에서 자격 증명을 가리고, 삭제는 명시적 동의(opt-in)가 있어야만 허용됩니다.
기능
모니터링 — 워커/클러스터 정보, 커넥터 목록, 커넥터별 구성, 상태(실패한 태스크 추적 포함), 토픽.
관리 — 생성/수정, 일시 중지/재개, 커넥터 또는 단일 태스크 재시작.
수명 주기 — 커넥터 삭제(admin).
접근 모드 —
read-only→read-write→admin으로 계층화되어, 어떤 모드도 자신보다 높은 수준의 도구를 노출하지 않습니다.자격 증명 가림 — 결과가 반환되기 전에
database.password및 기타 비밀 형식의 구성 값이***REDACTED***로 대체됩니다.보안 플래그 — 커넥터 허용 목록, 보호된 커넥터, 삭제 게이팅, dry-run, JSON 감사 로깅(아래 참조).
Related MCP server: Kafka MCP Server
보안 모델
고려 사항 | 플래그 | 기본값 | 설명 |
서버는 무엇을 할 수 있나요? |
|
|
|
범위에 포함되는 커넥터는 무엇인가요? |
| (모두) | 이 값이 설정되면 다른 커넥터에 대한 작업은 거부됩니다. |
어떤 커넥터가 영구적으로 읽기 전용인가요? |
| (없음) | 검사는 가능하지만 일시 중지/재구성/삭제는 불가능합니다. |
삭제할 수 있나요? |
|
|
|
Connect를 건드리지 않고 미리 보기 |
|
| 쓰기/admin 도구는 의도를 검증하고 기록한 뒤 반환합니다. |
감사 추적 |
|
| 보호되는 각 작업에 대해 stderr에 JSON 줄을 출력합니다. |
자격 증명 가림 | (항상 켜짐) | — | 비밀 형식의 구성 값은 반환 전에 가려집니다. |
도구
읽기 (read-only+): cluster_info, list_connectors, list_connector_plugins, get_connector, get_connector_config, get_connector_status, get_connector_topics
쓰기 (read-write+): create_connector, update_connector_config, pause_connector, resume_connector, restart_connector, restart_task
관리자 (admin): delete_connector (DEBEZIUM_ALLOW_DELETE 필요)
MCP 클라이언트와 함께 사용
Claude Code, Claude Desktop, Cursor, OpenAI Codex CLI, Windsurf, VS Code(Copilot) 및 기타 모든 MCP 클라이언트와 함께 작동합니다. 클라이언트별 설정은 docs/CLIENTS.md 를 참고하세요.
설치
npm install
npm run buildClaude Desktop / Claude Code로 실행
{
"mcpServers": {
"debezium": {
"command": "node",
"args": ["/absolute/path/to/mcp-debezium/dist/index.js"],
"env": {
"CONNECT_URL": "http://connect:8083",
"DEBEZIUM_MODE": "read-only",
"DEBEZIUM_PROTECTED_CONNECTORS": "pg-prod-orders"
}
}
}
}예시 프롬프트
"어떤 커넥터가 FAILED 상태이며, 그 이유는 무엇인가요?"
"
pg-orders의 실패한 태스크를 재시작하세요." (read-write필요)"
mysql-inventory의 구성을 보여주세요." (자격 증명은 가려진 상태로 반환됩니다)
개발
npm run dev
npm test # security policy + config redaction
npm run typecheck배포
이 서버에는 공식 MCP 레지스트리용 server.json과 npm 소유권 검증용 mcpName이 포함되어 있습니다. npm에 배포하고 MCP 레지스트리, Smithery, Glama, Cursor, PulseMCP에 등록하는 방법은 PUBLISHING.md 를 참조하세요.
라이선스
MIT
Maintenance
Resources
Unclaimed servers have limited discoverability.
Looking for Admin?
If you are the server author, to access and configure the admin panel.
Related MCP Servers
- FlicenseNot gradedqualityDmaintenanceEnables AI assistants to manage and monitor Apache Kafka clusters through natural language, providing real-time operations, health monitoring, consumer lag analysis, and temporal trend detection for intelligent cluster management.
- AlicenseNot gradedqualityDmaintenanceEnables interaction with Kafka clusters via MCP, supporting topic management (list, create, delete, inspect), connection initialization, and more through natural language.1Apache 2.0
- FlicenseCqualityBmaintenanceExposes Kafka administration operations as MCP tools, enabling AI agents to inspect Kafka clusters using natural language.1
- FlicenseNot gradedqualityDmaintenanceEnables AI-powered MCP clients to interact with data lakehouse components including Kafka, Flink, and Trino/Iceberg for managing topics, jobs, catalogs, and executing queries.2
Related MCP Connectors
GibsonAI MCP server: manage your databases with natural language
Official Microsoft MCP Server to query Microsoft Entra data using natural language
Remote MCP for GenAI span mapping, provider normalization, dashboard schemas, and receipts.
Latest Blog Posts
- Who's Calling? MCP Hosts Are an Identity Blind Spot (And the Spec Knows It)By Om-Shree-0709 on .mcpAgent IdentityOAuth 2.1
- Your AI Chatbot Just Exposed Your CEO's Salary to an InternBy Om-Shree-0709 on .Agent IdentityMCP SecurityOAuth Delegation
- Why MCP Servers Need Execution Sandboxing (And Why Your Current Stack Isn't Enough)By Om-Shree-0709 on .Agentic AiPrompt InjectionWebAssembly
MCP directory API
We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/dockndevai/mcp-debezium'
If you have feedback or need assistance with the MCP directory API, please join our Discord server