카프카 토픽 생성 에러(ERROR org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication factor: 1 larger than available brokers: 0)

카프카를 실행시킨 후, 카프카 토픽을 생성할 때 다음과 같은 에러가 발생하는 경우가 있다.

토픽 생성 명령어 : 

$ /usr/local/kafka/bin/kafka-topics.sh --zookeeper zk01:2181,zk02:2181,zk03:2181/kafka_znode1 --replication-factor 1 --partitions 1 --topic topic1 --create

 

에러 메시지 : 

Error while executing topic command : Replication factor: 1 larger than available brokers: 0.
[2020-12-13 13:56:31,240] ERROR org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication factor: 1 larger than available brokers: 0.
 (kafka.admin.TopicCommand$)

 

 

확인 결과 카프카 설정파일(카프카 설치 디렉토리 / config / server.properties)에 설정되어 있는 주키퍼 정보와 토픽 생성 시 입력한 주키퍼 정보가 불일치해서 발생한 에러였다. 카프카 설정파일에 명시되어 있는 주키퍼 정보를 토픽 생성 명령어에 동일하게 입력하여 에러를 해결하였다.

카프카 설치 디렉토리 / config / server.properties :

...

############################# Zookeeper #############################

# Zookeeper connection string (see zookeeper docs for details).
# This is a comma separated host:port pairs, each corresponding to a zk
# server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002".
# You can also append an optional chroot string to the urls to specify the
# root directory for all kafka znodes.
zookeeper.connect=zk01:2181,zk02:2181,zk03:2181/kafka01_znode


# Timeout in ms for connecting to zookeeper
zookeeper.connection.timeout.ms=18000

...

 

수정된 토픽 생성 명령어 : 

$ /usr/local/kafka/bin/kafka-topics.sh --zookeeper zk01:2181,zk02:2181,zk03:2181/kafka01_znode --replication-factor 1 --partitions 1 --topic topic1 --create

 

---

참고

www.programmersought.com/article/97982099469/ 

ERROR InvalidReplicationFactorException: Replication factor: 1 larger than available brokers: 0 - Programmer Sought