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 <vkeylis2...@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) >
