- 첨부된 프로젝트의 압축을 푼다.
- CMD창을 연다
- DebeziumCDC\src\main\resources로 폴더를 이동한다.
- docker-compose -f docker-compose-mysql.yaml up 명령어를 실행한다.
- Docker에 my sql을 docker-compose를 통해 실행됨을 확인할 수 있다.
- 2개의 mysql서버가 구동되고 있다 하나는 source용 mysql:3305 다른 하나는 target용 mysql:3306이다
- username : root password : root로 DBeaver에서 접속해 본다.
- DebeziumCDC\src\main\resources\customer.sql의 명령어를 차례대로 실행한다.
- customer테이블을 생성하고 springboot 프로젝트를 실행하여 DebeziumListener에 handleChangeEvent 메서드에 Break point를 걸고 customer테이블에 데이터를 넣어본다
- break point에서 데이터가 들어오는걸 확인할수 있다.
Open Source/Kafka