테스트 환경
- Zookeeper 3대를 앙상블로 구현
- Kafka 의 server.properties 에 zookeeper 설정
설정 과정
- 한 서버에서 Zookeeper 프로세스 3대를 띄어서 앙상블로 구현
- 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
결과) 이후에 토픽 생성 명령어를 실행하면, 정상적으로 수행이 된다.