- kafka-cluster와 연결 성공
- kafka-cluster 는 docker-compose로 구현했고 producer는 그냥 도커 컨테이너 단위로 실행시키게 했다. 이유는 producer는 원하는 개수만큼 나중에 동적으로 컨테이너를 생성해야하기 때문에??
- 그래서 docker-compose 와 개개인의 container의 네트워크 연결을 위해 custom network를 만들고 그안에 다 매핑시켰다.
- topic name 과 받아오는 코인 종류는 BTC_KRW (나중에 인자값으로 받아오면 될듯하다)
- 커스텀 네트워크 생성
docker network create coin-pipeliner
- producer 이미지 빌드
docker build . -t coin-producer
- 카프카 클러스터 실행
docker-compose up --build -d
- 프로듀서 컨테이너 실행
docker run -d --network coin-pipeliner --name producer -p 9001:9001 -t coin-producer
- 테스트용 컨슈머 콘솔 실행
docker-compose exec kafka1 kafka-console-consumer --bootstrap-server kafka1:19091 kafka2:19092 kafka3:19093 --topic "dev.coin-pipeliner.KRW-BTC" --from-beginning