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)
