[NCP] kafka 터미널 데이터 전송

이전 글에서 kafka VM 생성, 접속 후 kafka Vm생성하기

[NCP] Ncp kafka VM 생성

위 VM생성 글에서  Broker노드 정보에서 PlainText 주소를 복사해서 위에 broker.list에 넣어준다.

cd /home/kafka_2.12-2.4.0
# topic list 출력하기
# [broker.list]에 앞에서 확인했던 브로커 노드 정보의 PlainText 복사본을 입력합니다.
./bin/kafka-topics.sh --bootstrap-server [broker.list] --list
# 해당 토픽을 생성하고 토픽에 메세지를 발행한다.
./bin/kafka-console-producer.sh --broker-list [broker.list] --topic [topic]
# 예시) ./bin/kafka-console-producer.sh --broker-list 192.168.2.24:9092,192.168.2.25:9092,192.168.2.26:9092 --topic test

해당 명령어가 실행되면 

>

꺽세모양이 나온다 - 종료 [Ctrl + C]

또 다른 터미널을 실행하여 Consumer VM에 접속한다.

--from-beginning 명령어를 사용할 경우, 해당 Topic에 대한 데이터를 처음부터 모두 조회한다.

cd /home/kafka_2.12-2.4.0
./bin/kafka-console-consumer.sh --bootstrap-server [bootstrap.server] --topic [topic] --from-beginning
# 위에서 입력했던 브로커 노드 정보의 PlainText 복사본을 입력한다.
# [topic]에 앞 단계 Producer VM에서 입력한 Topic을 입력한다.
# 예시) ./bin/kafka-console-consumer.sh --bootstrap-server 192.168.2.24:9092,192.168.2.25:9092,192.168.2.26:9092 --topic test --from-beginning

이전에 입력했던 메세지가 출력된다.