Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 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
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
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB