Zookeeper 및 Kafka 설치(Centos7) - 2

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

 

 

getting started

• 카프카에서 제공해주는 가장 기본적인 명령어를 시작
  • 토픽생성

      // bkjeon-topic 이라는 토픽을 생성하고 생성이 완료되면 Created topic "bkjeon-topic" 라고 출력된다.
      $ /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 1 --partitions 1 --topic bkjeon-topic --create
    

  • 토픽삭제

      // 브로커 환경설정에서 delete.topic.enable=true가 설정되어 있어야 한다.
      $ /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 --topic bkjeon-topic --delete
    

  • 카프카 topic으로 메세지를 입력하고 Ctrl + C 버튼을 같이 눌러 입력창에서 빠져나가자

      // 자신의 서버일경우 0.0.0.0 로 하자
      $ /home/bkjeon/app/kafka/bin/kafka-console-producer.sh --broker-list 0.0.0.0:9092,192.168.0.204:9092,192.168.0.205:9092 --topic bkjeon-topic
      $ > TEST
      # > TEST2
    

  • 프로듀서로부터 메세지를 받기

      // 자신의 서버일경우 0.0.0.0 로 하자
      // 입력하면 위의 topic으로 보낸 메시지가 출력된다.
      $ /home/bkjeon/app/kafka/bin/kafka-console-consumer.sh --bootstrap-server 0.0.0.0:9092,192.168.0.204:9092,192.168.0.205:9092 --topic bkjeon-topic --from-beginning