kafka.admin.AdminOperationException: replication factor: 3 larger than available brokers: 1

Searched on Google with the first line of a JAVA stack trace?

We can recommend more relevant solutions and speed up debugging when you paste your entire stack trace with the exception message. Try a sample exception.

Recommended solutions based on your search

Samebug tips

  1. ,
    Expert tip

    Verify on the createTopic command if you've set the right replication factor for the amount of brokers you have. Check as well if all your brokers are correctly setup and that they're alive when you create the topic.

  2. ,
    Expert tip

    If you're having problems using kafka in cluster, refer to this guide: https://goo.gl/tgWDjS

Solutions on the web

via GitHub by montana-ua
, 1 year ago
replication factor: 3 larger than available brokers: 1
via GitHub by ewencp
, 2 years ago
replication factor: 1 larger than available brokers: 0
via GitHub by mazharshaikh86
, 2 years ago
replication factor: 1 larger than available brokers: 0
via GitHub by jamesblackburn
, 2 years ago
replication factor: 1 larger than available brokers: 0
via GitHub by kjetilhp
, 2 years ago
replication factor: 3 larger than available brokers: 1
via GitHub by clockfly
, 1 year ago
replication factor: 1 larger than available brokers: 0
kafka.admin.AdminOperationException: replication factor: 3 larger than available brokers: 1	at kafka.admin.AdminUtils$.assignReplicasToBrokers(AdminUtils.scala:70)	at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:171)	at kafka.server.KafkaApis$$anonfun$19.apply(KafkaApis.scala:513)	at kafka.server.KafkaApis$$anonfun$19.apply(KafkaApis.scala:503)	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)	at scala.collection.immutable.Set$Set1.foreach(Set.scala:74)	at scala.collection.TraversableLike$class.map(TraversableLike.scala:244)	at scala.collection.AbstractSet.scala$collection$SetLike$$super$map(Set.scala:47)	at scala.collection.SetLike$class.map(SetLike.scala:93)	at scala.collection.AbstractSet.map(Set.scala:47)	at kafka.server.KafkaApis.getTopicMetadata(KafkaApis.scala:503)	at kafka.server.KafkaApis.handleTopicMetadataRequest(KafkaApis.scala:542)	at kafka.server.KafkaApis.handle(KafkaApis.scala:62)	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:59)	at java.lang.Thread.run(Thread.java:745)