테스트 환경

  • Zookeeper 3대를 앙상블로 구현
  • Kafka 의 server.properties 에 zookeeper 설정

설정 과정

  1. 한 서버에서 Zookeeper 프로세스 3대를 띄어서 앙상블로 구현
  2. Kafka 의 server.properties 설정 정보]
zookeeper.connect=localhost:2181,localhost:2182,localhost:2183

테스트


토픽 생성 Command

$ /path/kafka/kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 4

Zookeeper 서비스를 종료 (1개부터 2개까지 종료시키기)

- Zookeeper 프로세스 3개 중에서 1개를 종료

$ systemctl stop zookeeper1
$ /path/kafka/kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 4

결과) Created topic test-topic

- Zookeeper 프로세스를 3개 중에서 2개까지 종료

$ systemctl stop zookeeper2 
$ /path/kafka/kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 4  

결과) 토픽 생성하지 못하고 계속 대기...

- Zookeeper 프로세스를 다시 2개 이상으로 살리기

$ systemctl start zookeeper2

결과) 이후에 토픽 생성 명령어를 실행하면, 정상적으로 수행이 된다.

+ Recent posts