[Apache Kafka] Apache Camel을 이용한 Producer 설정

실행 테스트

zookeeper&kafka 컨테이너 실행

Docker를 이용해 zookeeper 및 kafka 컨테이너를 실행합니다. https://miiingo.tistory.com/196?category=702821 문서를 참고하세요. 

[Apache Kafka] Docker를 이용한 zookeeper, kafka 실행

위의 문서에서 제공하는 docker-compose.yaml 파일에서 KAFKA_ADVERTISED_LISTENERS 환경변수의 내용을 localhost가 아닌 해당 서버의 IP 주소로 변경합니다.

cd /opt/gopath/src/github.com/kafka-with-docker
# zookeeper&kafka 컨테이너 실행
docker-compose up -d
# zookeeper&kafka 컨테이너 실행 중지
docker-compose down

 

kafka topic 생성 확인

console을 이용하여 kafka 컨테이너에서 설정한 'javainuse-topic' topic이 제대로 생성되었는지 확인합니다.

cd /opt/gopath/src/github.com/kafka-with-docker/kafka_2.12-2.0.1
sh bin/kafka-topics.sh --zookeeper <서버의 IP 주소>:2181 --list

bin/kafka-topics.sh 옵션

• --zookeeper : zookeeper가 실행 중인 호스트. 별도의 서버에 구축했다면 server_ip:2181로 설정
• --list : 리스트 출력

 

kafka Consumer 실행

console을 이용해 kafka consumer를 실행하여 메시지 수신 상태로 대기시킵니다.

cd /opt/gopath/src/github.com/kafka-with-docker/kafka_2.12-2.0.1
bin/kafka-console-consumer.sh --topic javainuse-topic --bootstrap-server <서버의 IP 주소>:9092 --from-beginning

nodejs-kafka-example 프로젝트(https://github.com/CloudKarafka/nodejs-kafka-example)를 이용해 kafka consumer를 실행하여 메시지 수신 상태로 대기시킵니다.

cd /opt/gopath/src/github.com/kafka-with-docker
git clone https://github.com/CloudKarafka/nodejs-kafka-example.git
cd nodejs-kafka-example
npm install

export CLOUDKARAFKA_BROKERS="<서버의 IP 주소>:9092"
node consumer.js

 

kafka Producer 실행

Maven 프로젝트를 실행해 kafka Producer를 실행합니다.
Producer에서 보낸 내용이 Consumer에 출력되는 것을 확인합니다.