본문 바로가기

source3

Kafka로 CDC구현하기(3/3) - Kafka Sink Connector 생성해서 Postgres 연결하기 Kafka Sink Connector 생성해서 Postgres 연결하기 안녕하세요. 이번 글의 목표는 1. postgres 컨테이너 생성하기 2. Sink Connector 추가하기 3. 데이터 연동 확인하기 입니다. 1. postgres 컨테이너 생성하기 1.1 docker-compose.yml에 postgres 추가하기 docker-compose.yml 파일이 있는 곳으로 이동하여 docker-compose.yml을 수정합니다. postgres: image: postgres:14 container_name: postgres ports: - "5432:5432" environment: POSTGRES_ROOT_PASSWORD: admin POSTGRES_USER: postuser POSTGRES_PAS.. 2023. 6. 26.
Kafka로 CDC구현하기(2/3) - Kafka Sink Connector 생성해서 Mysql 연결하기 Kafka Sink Connector 생성하기 오늘은 Sink Connector를 생성해 보겠습니다. 저번시간에 Source Connector를 만들어서 Consumer를 확인해 봤죠? 2023.06.19 - [IT] - Kafka로 CDC구현하기(1/3) - Kafka Source Connector 생성하기 이번 포스팅의 목표는 Sink Connector를 생성하고 mysql 컨테이너를 추가하여 sinkdb의 데이터가 testdb의 데이터와 동기화될 수 있도록 할 것입니다! 이번 포스팅에서 할 일은 1. mysql(sinkdb) 컨테이너 추가하기 2. Source Connector 생성하기 3. 연동데이터 확인하기 입니다. 시작해보겠습니다. 1. mysql 컨테이너 추가하기 1.1 docker-comp.. 2023. 6. 20.
Kafka로 CDC구현하기(1/3) - Kafka Source Connector 생성하기 Kafka Source Connector 생성하기 이번 글의 목표는 1. Kafka 설치 2. Source Connector 생성하기 3. Consumer 생성하기 입니다! 환경 OCI centos 1.Kafka 설치하기 1.1 Docker를 이용하여 Kafka 및 필요프로그램을 설치해 줍니다. git clone https://github.com/wurstmeister/kafka-docker.git 1.2 설치가 완료되었다면 kafka-docker라는 폴더가 생성되어 있습니다. 1.3 폴더를 확인해 보면 위와 같이 여러 파일이 있을 겁니다. 설치할 때 필요한 파일은 docker-compose.yml입니다. 기타 이상한 파일들을 차차 설치할 예정이니 사진과 다르다고 당황하지 마세요~! 1.4 vi dock.. 2023. 6. 19.