NoBrokersForPartitionException

[Ott, Charles H.]

 

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