핵심 요약
KREAM은 Slack 대화 한 번으로 CDC 파이프라인 온보딩을 자동화했고, LangChain/LangGraph 기반 Megatron과 MCP를 연결한 실행 백엔드로 4개 레포의 흐름을 하나의 대화로 통합했습니다.
구현 방법
- Megatron 아키텍처: de-slack-bot, stream-orchestrator, kafka-connector, lakehouse-etl 연계
- Agentic Loop로 도구 목록을 런타임 가져와 판단/실행
- Slack 승인 게이트, /cdc new 흐름 및 UI 마법사 제공
- Spark 제출은 c3agent 사이드카를 통해 실행되고 Iceberg에 반영
주요 결과
- 신규 테이블의 등록·시작이 대화로 처리되어 수작업 감소
- 실행 로그가 stream-orchestrator에 모이고 운영 가시성 향상
- 정책 변경 시 엔진 재배포 없이 게이팅 조정 가능
