replication factor: 3 larger than available brokers: 1
[2018-12-15 07:25:43,621] ERROR org.apache.kafka.common.errors.InvalidReplicationFactorException: replication factor: 3 larger than available brokers: 1
(kafka.admin.TopicCommand$)
需要去看一下配置文件
vi server.properties
需要配置的参数:
############################# Server Basics #############################
broker.id=1
############################# Socket Server Settings #############################
listeners=PLAINTEXT://hadoop01:9092
############################# Log Basics #############################
log.dirs=/usr/local/kafka_2.11-0.10.2.1/data
############################# Zookeeper #############################
zookeeper.connect=hadoop01:2181,hadoop02:2181,hadoop03:2181
我出现的错误的原因是在启动多台kafka时的监听端口都配置成了:listeners=PLAINTEXT://hadoop01:9092导致的原因
关于kafka启动的命令:
/usr/local/kafka_2.11-0.10.2.1/bin/kafka-server-start.sh /usr/local/kafka_2.11-0.10.2.1/config/server.properties >> /var/kafka.log 2>&1 &
创建topic:
/usr/local/kafka_2.11-0.10.2.1/bin/kafka-topics.sh --create --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181 --replication-factor 3 --partitions 3 --topic user