[KAFKA-1238] New producer hangs in a loop detecting metadata for auto created topics

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Fix Version/s: 0.8.2.0
• Component/s: producer
• Assignee: Jay Kreps
• Reporter: Neha Narkhede
• Created: 03/Feb/14 00:10
• Updated: 22/Jul/14 14:38
• Resolved: 11/Feb/14 05:01

Description

New producer hangs in a loop detecting metadata for auto created topics -

java.lang.IllegalStateException: No known nodes.
at kafka.common.Cluster.nextNode(Cluster.java:97)
at kafka.clients.producer.internals.Sender.maybeMetadataRequest(Sender.java:154)
at kafka.clients.producer.internals.Sender.run(Sender.java:120)
at kafka.clients.producer.internals.Sender.run(Sender.java:84)
at java.lang.Thread.run(Thread.java:695)
java.lang.IllegalStateException: No known nodes.
at kafka.common.Cluster.nextNode(Cluster.java:97)
at kafka.clients.producer.internals.Sender.maybeMetadataRequest(Sender.java:154)
at kafka.clients.producer.internals.Sender.run(Sender.java:120)
at kafka.clients.producer.internals.Sender.run(Sender.java:84)
at java.lang.Thread.run(Thread.java:695)
java.lang.IllegalStateException: No known nodes.
at kafka.common.Cluster.nextNode(Cluster.java:97)
at kafka.clients.producer.internals.Sender.maybeMetadataRequest(Sender.java:154)
at kafka.clients.producer.internals.Sender.run(Sender.java:120)
at kafka.clients.producer.internals.Sender.run(Sender.java:84)
at java.lang.Thread.run(Thread.java:695)
java.lang.IllegalStateException: No known nodes.
at kafka.common.Cluster.nextNode(Cluster.java:97)
at kafka.clients.producer.internals.Sender.maybeMetadataRequest(Sender.java:154)
at kafka.clients.producer.internals.Sender.run(Sender.java:120)
at kafka.clients.producer.internals.Sender.run(Sender.java:84)
at java.lang.Thread.run(Thread.java:695)
java.lang.IllegalStateException: No known nodes.
at kafka.common.Cluster.nextNode(Cluster.java:97)
at kafka.clients.producer.internals.Sender.maybeMetadataRequest(Sender.java:154)
at kafka.clients.producer.internals.Sender.run(Sender.java:120)
at kafka.clients.producer.internals.Sender.run(Sender.java:84)
at java.lang.Thread.run(Thread.java:695)
java.lang.IllegalStateException: No known nodes.
at kafka.common.Cluster.nextNode(Cluster.java:97)
at kafka.clients.producer.internals.Sender.maybeMetadataRequest(Sender.java:154)
at kafka.clients.producer.internals.Sender.run(Sender.java:120)
at kafka.clients.producer.internals.Sender.run(Sender.java:84)
at java.lang.Thread.run(Thread.java:695)

The producer needs to be restarted to start sending data to the auto created topic