kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vadim Keylis <vkeylis2...@gmail.com>
Subject kafka.common.LeaderNotAvailableException: No leader for any partition
Date Thu, 30 May 2013 05:49:45 GMT
I am working on deploying Kafka 0.8 to our test cluster that consist of 2
kafka servers and 2 zookeper nodes.
I created topic using the following command

 bin/kafka-topics.sh --create --topic junit1_analytics_data_log --zookeeper
danalyticspubsubzoo02:2181 --partitions=36  --replication-factor=2

After using producer to post messages to the topic I am getting the
following error. Can someone please advise?
[2013-05-29 17:36:46,775] WARN Error while fetching metadata
PartitionMetadata(29,None,Vector(),Vector(),5) for topic partition
[junit1_analytics_data_log,29]: [class
kafka.common.LeaderNotAvailableException]
(kafka.producer.BrokerPartitionInfo)
[2013-05-29 17:36:46,775] WARN Error while fetching metadata
PartitionMetadata(30,None,Vector(),Vector(),5) for topic partition
[junit1_analytics_data_log,30]: [class
kafka.common.LeaderNotAvailableException]
(kafka.producer.BrokerPartitionInfo)
[2013-05-29 17:36:46,775] WARN Error while fetching metadata
PartitionMetadata(31,None,Vector(),Vector(),5) for topic partition
[junit1_analytics_data_log,31]: [class
kafka.common.LeaderNotAvailableException]
(kafka.producer.BrokerPartitionInfo)
[2013-05-29 17:36:46,776] WARN Error while fetching metadata
PartitionMetadata(32,None,Vector(),Vector(),5) for topic partition
[junit1_analytics_data_log,32]: [class
kafka.common.LeaderNotAvailableException]
(kafka.producer.BrokerPartitionInfo)
[2013-05-29 17:36:46,776] WARN Error while fetching metadata
PartitionMetadata(33,None,Vector(),Vector(),5) for topic partition
[junit1_analytics_data_log,33]: [class
kafka.common.LeaderNotAvailableException]
(kafka.producer.BrokerPartitionInfo)
[2013-05-29 17:36:46,776] WARN Error while fetching metadata
PartitionMetadata(34,None,Vector(),Vector(),5) for topic partition
[junit1_analytics_data_log,34]: [class
kafka.common.LeaderNotAvailableException]
(kafka.producer.BrokerPartitionInfo)
[2013-05-29 17:36:46,777] WARN Error while fetching metadata
PartitionMetadata(35,None,Vector(),Vector(),5) for topic partition
[junit1_analytics_data_log,35]: [class
kafka.common.LeaderNotAvailableException]
(kafka.producer.BrokerPartitionInfo)
[2013-05-29 17:36:46,777] WARN Failed to collate messages by
topic,partition due to (kafka.producer.async.DefaultEventHandler)
kafka.common.LeaderNotAvailableException: No leader for any partition
        at
kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$getPartition(DefaultEventHandler.scala:212)
        at
kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:150)
        at
kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:148)
        at
scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60)
        at
scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)
        at
kafka.producer.async.DefaultEventHandler.partitionAndCollate(DefaultEventHandler.scala:148)
        at
kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:94)
        at
kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:72)
        at kafka.producer.Producer.send(Producer.scala:74)
        at kafka.producer.ConsoleProducer$.main(ConsoleProducer.scala:159)
        at kafka.producer.ConsoleProducer.main(ConsoleProducer.scala)
[2013-05-29 17:36:46,880] INFO Fetching metadata with correlation id 6 for
1 topic(s) Set(junit1_analytics_data_log) (kafka.client.ClientUtils$)
[2013-05-29 17:36:46,881] INFO Connected to localhost:9092 for producing
(kafka.producer.SyncProducer)

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message