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

Switch to Threaded View
Kafka >> mail # user >> Producer Send error


Copy link to this message
-
Re: Producer Send error
The error indicates that somehow there is a topic with 0 partition created.
Not sure how this happened. Is this reproducible?

Thanks,

Jun

On Thu, Feb 28, 2013 at 4:53 PM, zayeem <[EMAIL PROTECTED]> wrote:

> When trying to create a topic and sending a test payload results in the
> following error message.
>
> ERROR [main][kafka.producer.async.DefaultEventHandler] Failed to collate
> messages by topic, partition due to
> kafka.common.NoBrokersForPartitionException: Partition key = null
> at
>
> kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$getPartitionListForTopic(DefaultEventHandler.scala:189)
>  at
>
> kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:148)
> at
>
> kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:147)
>  at
>
> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60)
> at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)
>  at
>
> kafka.producer.async.DefaultEventHandler.partitionAndCollate(DefaultEventHandler.scala:147)
> at
>
> kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:93)
>  at
>
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:72)
> at kafka.producer.Producer.send(Producer.scala:76)
>  at kafka.javaapi.producer.Producer.send(Producer.scala:41)
> at
>
> org.springframework.integration.kafka.core.KafkaAdapterExecutor.sendMessages(KafkaAdapterExecutor.java:132)
>
> Are there steps that i am missing after creation of the topic?
>
> Regards
> Zayeem
>