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

Switch to Threaded View
Kafka, mail # user - Re: NoBrokersForPartitionException


Copy link to this message
-
Re: NoBrokersForPartitionException
Jun Rao 2013-07-21, 23:22
Casey,

I am not exactly sure what's causing this particular issue. However, a
bunch of produce side issues got fixed in 0.7.2.

Thanks,

Jun
On Mon, Jul 15, 2013 at 5:11 AM, Sybrandy, Casey <
[EMAIL PROTECTED]> wrote:

> Jun,
>
> Unfortunately, upgrades are slow to occur with respect to projects, so I
> don't know when this will occur.  However, it looks like we will be
> upgrading over the next couple months to 0.7.2.
>
> Regardless, what is causing this?  Is this a bug in Kafka or is it
> something that triggered by something we did?  I only ask because it looked
> like the directories for the specific topic I was looking for disappeared,
> so it seemed like someone deleted them.
>
> Casey
>
> -----Original Message-----
> From: Jun Rao [mailto:[EMAIL PROTECTED]]
> Sent: Thursday, July 11, 2013 1:17 AM
> To: [EMAIL PROTECTED]
> Subject: Re: NoBrokersForPartitionException
>
> Could you try 0.7.2?
>
> Thanks,
>
> Jun
>
>
> On Wed, Jul 10, 2013 at 11:38 AM, Sybrandy, Casey <
> [EMAIL PROTECTED]> wrote:
>
> > Hello,
> >
> > Apologies for bringing this back from the dead, but I'm getting the
> > same exception using Kafka 0.7.0.  What could be causing this?
> >
> > Thanks.
> >
> > Casey
> >
> > -----Original Message-----
> > From: Jun Rao [mailto:[EMAIL PROTECTED]]
> > Sent: Tuesday, March 12, 2013 12:14 AM
> > To: [EMAIL PROTECTED]
> > Subject: 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$$getPartitionListFor
> > > To
> > > pi
> > > 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(IndexedSeqOptimiz
> > > ed
> > > .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(KafkaProducerCon
> > > ne
> > > ct
> > > 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
> > >
> > >
> >
>