[Kafka 클러스터 환경 구축] 7강. Kafka, Zookeeper 실행

 

 

## Zookeeper 실행

 

## Zookeeper 실행 확인

 

## Zookeeper 리스닝 포트 확인

 

 

 

 

 

 

## Kafka 실행  (-daemon 옵션으로 백그라운드로 실행 할 것)

 

 

 

 

## Kafka 리스닝 포트 확인

 

 

 

 

 

 

## Zookeeper znode 확인

 

 

 

 

 

 

========================================================

 

 

• Zookeeper 실행

: 설명 편의를 위해 kafka01 서버로 이동하여 진행한다.

# EC2 Ubuntu terminal(kafka03)

# kafka03 서버 -> kafka01 서버
ssh kafka01

# EC2 Ubuntu terminal(kafka01)

# Kafka01 zookeeper start
$ZOOKEEPER_HOME/bin/zkServer.sh start

# Kafka02 zookeeper start
ssh kafka02 "$ZOOKEEPER_HOME/bin/zkServer.sh start"

# Kafka03 zookeeper start
ssh kafka03 "$ZOOKEEPER_HOME/bin/zkServer.sh start"

• Zookeeper 실행 확인

: zkServer.sh status 명령으로 각 서버의 zookeeper 실행 상태를 확인할 수 있다. 정상 실행 되었다면, Leader, Follower 와 같이 출력될 것이다.

# EC2 Ubuntu terminal(kafka01)

# Kafka01 zookeeper status
$ZOOKEEPER_HOME/bin/zkServer.sh status

# Kafka02 zookeeper status
ssh kafka02 "$ZOOKEEPER_HOME/bin/zkServer.sh status"

# Kafka03 zookeeper status
ssh kafka03 "$ZOOKEEPER_HOME/bin/zkServer.sh status"

• Zookeeper 리스닝 포트 확인

: 각 서버에서 2181 포트를 리스닝 중이라면 정상 실행 중인 것이다.

# EC2 Ubuntu terminal(kafka01)

# Kafka01 zookeeper port check
netstat -nltp | grep 2181

# Kafka02 zookeeper port check
ssh kafka02 "netstat -nltp | grep 2181"

# Kafka03 zookeeper port check
ssh kafka03 "netstat -nltp | grep 2181"

• Kafka 실행

# EC2 Ubuntu terminal(kafka01)

# Kafka01 Start
$KAFKA_HOME/bin/kafka-server-start.sh -daemon $KAFKA_HOME/config/server.properties

# Kafka02 Start
ssh kafka02 "$KAFKA_HOME/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties"

# Kafka03 Start
ssh kafka03 "$KAFKA_HOME/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties"

• Kafka 리스닝 포트 확인

: 각 서버에서 9092 포트를 리스닝 중이라면 정상 실행 중인 것이다.

# EC2 Ubuntu terminal(kafka01)

# Kafka01 kafka port check
netstat -nltp | grep 9092

# Kafka02 kafka port check
ssh kafka02 "netstat -nltp | grep 9092"

# Kafka03 kafka port check
ssh kafka03 "netstat -nltp | grep 9092"

• Zookeeper znode 확인

# EC2 Ubuntu terminal(kafka01)

# zookeeper cli 실행
$ZOOKEEPER_HOME/bin/zkCli.sh

# znode root 디렉토리 검색
ls /  # my-kafka-cluster 가 출력 되면 정상

# znode kafka brokers의 id 확인
ls /my-kafka-cluster/brokers/ids  # 1, 2, 3 이 출력 되면 정상

# znode kafka brokers의 topic 리스트 확인
ls /my-kafka-cluster/brokers/topics