Zookeeper 및 Kafka 설치(Centos7) - 3

이전글은 https://bkjeon1614.tistory.com/638 를 참고하도록 하자.

 

콘솔 프로듀서로 메세지 보내기

• 예시 토픽 생성

    // kafka 1번 서버에서 카프카 명령을 실행하자
    // 토픽이름: bkjeon-topic
    // 파티션: 1
    // 리플리케이션 팩터: 3
    $ /home/bkjeon/app/kafka/bin/kafka-topics.sh --zookeeper 192.168.0.200:2181,192.168.0.201:2181,192.168.0.202:2181/bkjeon-kafka --replication-factor 3 --partitions 1 --topic bkjeon-topic --create
  
    // 하기 명령으로 토픽의 리플리케이션, ISR, 리더와 팔로워 등의 상세 정보를 확인이 가능하다.
    $ /home/bkjeon/app/kafka/bin/kafka-topics.sh --zookeeper 192.168.0.200:2181/bkjeon-kafka --topic bkjeon-topic --describe
  

• 토픽에 메세지 전송

    $ /home/bkjeon/app/kafka/bin/kafka-console-producer.sh --broker-list 192.168.0.203:9092,192.168.0.204:9092,192.168.0.205:9092 --topic bkjeon-topic
  
    // 토픽에 보내고 싶은 내용을 입력하자. (상기 명령을 실행하면 토픽에 보낼 메세지를 입력할 수 있게 된다.) 입력후 Ctrl + C 를 눌러 빠져나오자.
    $ > hello bkjeon
  
    // 보낸 메세지가 잘 전송되었는지 확인
    $ /home/bkjeon/app/kafka/bin/kafka-console-consumer.sh --bootstrap-server 192.168.0.203:9092,192.168.0.204:9092,192.168.0.205:9092 --topic bkjeon-topic --from-beginning