Could you do a list topic and show the output? Also, any error in the
controller and state-change log?
Thanks,
Jun
On Fri, Feb 21, 2014 at 2:33 AM, Arjun <ar...@socialtwist.com> wrote:
> hi,
>
> I am testing kafka 0.8 on my local machine. i have only one zookeeper and
> one kafka broker running.
>
> when i run the console producer i get this error:
>
> [2014-02-21 16:01:20,512] WARN Error while fetching metadata
> [{TopicMetadata for topic test ->
> No partition metadata for topic test due to
> kafka.common.LeaderNotAvailableException}]
> for topic [test]: class kafka.common.LeaderNotAvailableException
> (kafka.producer.BrokerPartitionInfo)
> [2014-02-21 16:01:20,513] ERROR Failed to collate messages by topic,
> partition due to: Failed to fetch topic metadata for topic: test
> (kafka.producer.async.DefaultEventHandler)
> [2014-02-21 16:01:20,632] WARN Error while fetching metadata
> [{TopicMetadata for topic test ->
> No partition metadata for topic test due to
> kafka.common.LeaderNotAvailableException}]
> for topic [test]: class kafka.common.LeaderNotAvailableException
> (kafka.producer.BrokerPartitionInfo)
> [2014-02-21 16:01:20,636] ERROR Failed to send requests for topics test
> with correlation ids in [0,8] (kafka.producer.async.DefaultEventHandler)
> ERROR Error in handling batch of 1 events (kafka.producer.async.
> ProducerSendThread)
> kafka.common.FailedToSendMessageException: Failed to send messages after
> 3 tries.
> at kafka.producer.async.DefaultEventHandler.handle(
> DefaultEventHandler.scala:90)
> at kafka.producer.async.ProducerSendThread.tryToHandle(
> ProducerSendThread.scala:104)
> at kafka.producer.async.ProducerSendThread$$anonfun$
> processEvents$3.apply(ProducerSendThread.scala:87)
> at kafka.producer.async.ProducerSendThread$$anonfun$
> processEvents$3.apply(ProducerSendThread.scala:67)
> at scala.collection.immutable.Stream.foreach(Stream.scala:254)
> at kafka.producer.async.ProducerSendThread.processEvents(
> ProducerSendThread.scala:66)
> at kafka.producer.async.ProducerSendThread.run(
> ProducerSendThread.scala:44)
>
> Can some one please let me know why this is happening.
> I checked my vhost files and localhost, my hostname are correct.
>
