[ 제 3강 소비와 생산 ] KAFKA Producer & Consumer

KAFKA의 생산과 소비를 테스트 하려 합니다.

 

 

우선 컨슈머 셋팅을 하겠습니다. 우리가 이전 시간에 생성했던 토픽을 활용합니다.

 

아래와 같이 컨슈머를 실행하면, 아래 이미지와 같은 console이 생성 됩니다. 어떤 현상이 발생 한다기 보다는 그냥 로그를 확인하는 창과 비슷합니다. 이벤트가 발생하면 찍히는

kafka-console-consumer --bootstrap-server 192.168.2.77:9092,192.168.2.78:9092,192.168.2.79:9092 --topic example-topic

consumer 실행

 

이제 프로듀서를 실행해 보겠습니다.

아래와 같이 프로듀서를 실행하면 > 프롬프트 상태로 멈춰 있는데요, 이제 거기에 어떤한 모든 메시지를 입력하면 되겠죠~

kafka-console-producer --broker-list 192.168.2.77:9092,192.168.2.78:9092,192.168.2.79:9092 --topic example-topic

producer실행

 

프로듀서 창에서 아래와 같이 입력해서 테스트 해보겠습니다.

kafka-console-producer --broker-list 192.168.2.77:9092,192.168.2.78:9092,192.168.2.79:9092 --topic example-topic
>KAFKA TEST 1
>KAFKA TEST 2
>KAFKA TEST 3
>KFAKA TEST 4

위 이미지와 같이 consumer를 실행 시켰던 창에 방금 producer에서 입력했던 메시지 들이 출력되는 결과를 볼 수 있습니다.

 

 

궁금사항은 댓글 달아주세요^&^