Which version of Kafka are you using? Thanks,
Jun On Mon, Mar 11, 2013 at 12:30 PM, Ott, Charles H. <charles.h....@saic.com>wrote: > > > I am trying to do something like this: > > 1.) Java Client Producer(Sever A) -> Zookeeper (Server B) to getKafka > service. > > 2.) Zookeeper gives IP for Kafka (Server C) to Producer (Server A) > > 3.) Producer (Server A) attempts to publish message to Kafka (Server > C) using IP resolved from zookeeper. > > > > I am getting an error when attempting to write a message to a Kafka > topic. > > > > kafka.common.NoBrokersForPartitionException: Partition = null > > at > kafka.producer.Producer.kafka$producer$Producer$$getPartitionListForTopi > c(Producer.scala:167) > > at kafka.producer.Producer$$anonfun$3.apply(Producer.scala:116) > > at kafka.producer.Producer$$anonfun$3.apply(Producer.scala:105) > > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.sc > ala:206) > > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.sc > ala:206) > > at > scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.s > cala:34) > > at > scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:32) > > at > scala.collection.TraversableLike$class.map(TraversableLike.scala:206) > > at > scala.collection.mutable.WrappedArray.map(WrappedArray.scala:32) > > at kafka.producer.Producer.zkSend(Producer.scala:105) > > at kafka.producer.Producer.send(Producer.scala:99) > > at kafka.javaapi.producer.Producer.send(Producer.scala:103) > > at > com.saic.project.kafka.KafkaProducerConnection.push(KafkaProducerConnect > ion.java:76) > > > > I believe this implies that the Java Client cannot publish to the Kafka > server. How would I go about trouble shooting this? What does > NoBrokersForPartition mean? Currently I have a different Client (Server > D) that is able to publish messages with custom topic to Server C > without error. > > > > Thanks, > > Charles > >
