kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jun Rao <jun...@gmail.com>
Subject Re: kafka.common.LeaderNotAvailableException: No leader for any partition
Date Thu, 30 May 2013 15:14:32 GMT
Are you using the latest code from the 0.8 branch? Any exception/error in
the broker log (including state-change.log)?

Thanks,

Jun


On Wed, May 29, 2013 at 10:49 PM, Vadim Keylis <vkeylis2009@gmail.com>wrote:

> 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