Error while executing topic command : org.apache.kafka.common.errors.InvalidReplicationFactorExcepti
[root@node01 kafka]# bin/kafka-topics.sh --create --bootstrap-server node01:9092 --replication-factor 2 --partitions 2 --topic mytestError while executing topic command : org.apache.kafka.common.erro.
·
[root@node01 kafka]# bin/kafka-topics.sh --create --bootstrap-server node01:9092 --replication-factor 2 --partitions 2 --topic mytest
Error while executing topic command : org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication factor: 2 larger than available brokers: 1.
[2020-02-03 16:08:58,131] ERROR java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication factor: 2 larger than available brokers: 1.
at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
at org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)
at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:260)
at kafka.admin.TopicCommand$AdminClientTopicService.createTopic(TopicCommand.scala:242)
at kafka.admin.TopicCommand$TopicService$class.createTopic(TopicCommand.scala:194)
at kafka.admin.TopicCommand$AdminClientTopicService.createTopic(TopicCommand.scala:217)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:61)
at kafka.admin.TopicCommand.main(TopicCommand.scala)
Caused by: org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication factor: 2 larger than available brokers: 1.
(kafka.admin.TopicCommand$)
这个错呢你可以看报错信息Replication factor: 2 larger than available brokers: 1.,他说Replication是1,但是你设置的是2大于了1
改一下就好了改成–replication 1
bin/kafka-topics.sh --create --bootstrap-server node01:9092 --replication-factor 1 --partitions 2 --topic mytest
改完你可以去查看一下看看有没有创建成功
root@node01 kafka]# bin/kafka-topics.sh --list --bootstrap-server node01:9092
__consumer_offsets
connect-test
javatest
mytest
test
更多推荐
所有评论(0)