하나의 VM에 Zookeeper와 kafka를 모두 설치하여 1개의 broker만 설치

  * 이후 세션에서 3대의 VM으로 클러스터링 예정

 

<설치 방법>

1.tar파일 다운로드  및 압축 풀기

   - wget https://downloads.apache.org/kafka/2.7.0/kafka_2.13-2.7.0.tgz

   - cd kafka_2.13-2.7.0

 

2. 주키퍼 실행 및 카프카 실행 ( 주키퍼 먼저 실행 )

   -./zookeeper-server-start.sh -daemon ../config/zookeeper.properties

   - ps -ef | grep zookeeper

   - ./kafka-server-start.sh -daemon ../config/server.properties

   - ps -ef | grep kafka

 

 

* zookeeper, kafka 서버 내리기  ( 내리는 순서 상관 없음 )

   - ./kafka-server-stop.sh

   - ./zookeeper-server-stop.sh

 

* 토픽 보기

   - ./kafka-topics.sh --list --zookeeper localhost:2181

 

* 토픽 생성 

   - ./kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic <토픽명>

 

* 토픽 삭제

  - ./kafka-topics.sh --zookeeper localhost:2181 --delete --topic <토픽명>

 

* 토픽 데이터 읽기

  - ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic 토픽명 --from-beginning

+ Recent posts