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

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.

tip

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

You have a different solution? A short tip here would help you and many other users who saw this issue last week.

  • GitHub comment 127#249504347
    via GitHub by xiaomayilj
    ,
  • GitHub comment 101#266557910
    via GitHub by johnrgregg3
    ,
  • The crash of kafka server and heka fiter
    via Stack Overflow by See Wei
    ,
  • GitHub comment 44#252938012
    via GitHub by Lawouach
    ,
  • [ut]KafkaStreamProducerSpec fail
    via GitHub by clockfly
    ,
  • GitHub comment 200#142925291
    via GitHub by kjetilhp
    ,
  • GitHub comment 17#166511969
    via GitHub by ewencp
    ,
    • kafka.admin.AdminOperationException: replication factor: 3 larger than available brokers: 1 at kafka.admin.AdminUtils$.assignReplicasToBrokers(AdminUtils.scala:117) at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:403) at kafka.server.KafkaApis.kafka$server$KafkaApis$$createTopic(KafkaApis.scala:629) at kafka.server.KafkaApis.kafka$server$KafkaApis$$createGroupMetadataTopic(KafkaApis.scala:651) at kafka.server.KafkaApis$$anonfun$29.apply(KafkaApis.scala:668) at kafka.server.KafkaApis$$anonfun$29.apply(KafkaApis.scala:666) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) at scala.collection.immutable.Set$Set1.foreach(Set.scala:94) at scala.collection.TraversableLike$class.map(TraversableLike.scala:234) at scala.collection.AbstractSet.scala$collection$SetLike$$super$map(Set.scala:47) at scala.collection.SetLike$class.map(SetLike.scala:92) at scala.collection.AbstractSet.map(Set.scala:47) at kafka.server.KafkaApis.getTopicMetadata(KafkaApis.scala:666) at kafka.server.KafkaApis.handleTopicMetadataRequest(KafkaApis.scala:727) at kafka.server.KafkaApis.handle(KafkaApis.scala:79) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60) at java.lang.Thread.run(Thread.java:745)

    Users with the same issue

    Unknown visitor1 times, last one,
    roioteromorales
    roioteromorales1 times, last one,
    Unknown visitor1 times, last one,