Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Plain View
Kafka, mail # user - NoBrokersForPartitionException


+
Ott, Charles H. 2013-03-11, 19:35
Copy link to this message
-
Re: NoBrokersForPartitionException
Jun Rao 2013-03-12, 04:14
Which version of Kafka are you using?

Thanks,

Jun

On Mon, Mar 11, 2013 at 12:30 PM, Ott, Charles H. <[EMAIL PROTECTED]>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
>
>

 
+
Jun Rao 2013-07-11, 05:17