구축 목표] 실시간으로 Source DB의 데이터가 변할 때 Debezium Kafka Connecter 를 통해 consumer 에게 메세지 보내고 해당 데이터 ( Json 형식의 string type) 을 paylaod 부분 추출하여 MongoDB에 저장. 주요 과제] kafka connector 에서 제공되는 log는 json 형식의 굉장히 긴 String 값입니다. debezium document에서 제공되는 key를 접근하는 방법 탐구, 및 디비 저장 구현 예상도] 구축 환경 window - Producer ] - DB : MongoDB - zookeeper server - Kafka server - Kafka connect - Debezium connector window- Consumer ]..

목표] Springboot 에 Mongodb 연결후 데이터 삽입 확인 Tool : Intellij DB: MongoDB 빌더 : Maven --- 1. Springboot project 생성 next 다음에는 3가지 Dependency 추가한다 pom.xml 에 다음 Dependency 추가 org.springframework.boot spring-boot-starter-data-mongodb +Lombok 은 @Data 어노테이션으로 Getter 와 Setter을 쓰지 않아도 되는 간편함을 제공한다. 본문에서는 getter와 setter를 적용하고 진행하겠습니다. 2. application.propertise 추가] spring.data.mongodb.host=localhost spring.data.m..

목표] 순수 java로 Mongodb 에 연결하여 데이터를 읽고, 쓰기 Tool : Intellij DB : MongoDB 빌더 : Maven Intellij로 Maven 프로젝트를 하나 만듭니다] 2. Pom.xml 에 Dependency 추가 org.mongodb mongo-java-driver 3.4.1 3. 자바 파일 2개 생성 4. Mongodb 에는 연결을 하고 Collection 객체를 반환하게 만들었습니다. ublic class Mongodb { public DBCollection collection; // 콜렉션 객체 반환 public DBCollection selectMongo(){ return collection; } public Mongodb() { //생성자 호출과 동시에 연결 /..

1. MongoDB 설치] Docker 를 이용하여 MongoDB를 설치하였습니다. docker 설치는 다음 포스트 참고 https://yn971106.tistory.com/73?category=1003066 [Docker]_Infra 구축_(feat. Centos7, wsl2) 목표 ] Window 환경에서 CentOS7 을 WSL2 환경에 실행후 해당 CentOS7 안에 Docker 실행하기. Docker 란? 경량 가상화 기술이며 리눅스 컨테이너를 기반으로 이미지를 기준으로 프로세스를 격리하여 yn971106.tistory.com 도커 이미지 가져오기] $ docker pull mongo 지금 가져온 전체 이미지 확인하기] $ docker images container 생성 및 실행] $ docke..