카프카를 실행시킨 후, 카프카 토픽을 생성할 때 다음과 같은 에러가 발생하는 경우가 있다.
토픽 생성 명령어 :
$ /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
background kafka 2.3 version to establish a new topic when a new topic error [email protected] kafka_2.11-2.3.0$ ./bin/kafka-topics.sh --create --zookeeper localhost:2181,localhost:2182,localhost:2183 --replication-factor 1 --partitions 1 --topic lcc_xjj1
www.programmersought.com
댓글