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 Threaded View
Kafka >> mail # user >> Kafka cannot produce message


Copy link to this message
-
Re: Kafka cannot produce message
Apache email doesn't allow attachment. Could you try the latest code in the
0.8 branch and see if the same issue exists?

Thanks,

Jun
On Thu, Oct 10, 2013 at 10:20 PM, Jiang Jacky <[EMAIL PROTECTED]> wrote:

>
> for those 2 logs directly in my ~/kafka_2.8.0-0.8.0-beta1, Maybe I did not
> set the log output to indicated directory.
> I will attach my 3 logs to you. server.log, controller.log and
> state-change.log
>
> for testing, I changed the port to 9093, and each time, I produce message
> it gives me error
>
> [2013-10-11 05:12:16,948] INFO Fetching metadata from broker
> id:0,host:localhost,por
>
>                                                           t:9093 with
> correlation id 0 for 1 topic(s) Set(my-replicated-topic) (kafka.client.C
>
>
>                                 lientUtils$)
> [2013-10-11 05:12:16,966] INFO Connected to localhost:9093 for producing
> (kafka.prod
>
>                                               ucer.SyncProducer)
> [2013-10-11 05:12:16,997] ERROR [KafkaApi-0] Error while fetching metadata
> for parti
>
>                                             tion [my-replicated-topic,0]
> (kafka.server.KafkaApis)
> kafka.common.LeaderNotAvailableException: Leader not available for
> partition [my-rep
>
>                                                     licated-topic,0]
>         at
> kafka.server.KafkaApis$$anonfun$17$$anonfun$20.apply(KafkaApis.scala:468)
>         at
> kafka.server.KafkaApis$$anonfun$17$$anonfun$20.apply(KafkaApis.scala:456)
>         at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.sca
>
>
>                                 la:206)
>         at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.sca
>
>
>                                 la:206)
>         at
> scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scal
>
>
>                                 a:61)
>         at scala.collection.immutable.List.foreach(List.scala:45)
>         at
> scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
>         at scala.collection.immutable.List.map(List.scala:45)
>         at kafka.server.KafkaApis$$anonfun$17.apply(KafkaApis.scala:456)
>         at kafka.server.KafkaApis$$anonfun$17.apply(KafkaApis.scala:452)
>         at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.sca
>
>
>                                 la:206)
>         at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.sca
>
>
>                                 la:206)
>         at scala.collection.immutable.Set$Set1.foreach(Set.scala:81)
>         at
> scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
>         at scala.collection.immutable.Set$Set1.map(Set.scala:68)
>         at
> kafka.server.KafkaApis.handleTopicMetadataRequest(KafkaApis.scala:452)
>         at kafka.server.KafkaApis.handle(KafkaApis.scala:69)
>         at
> kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42)
>         at java.lang.Thread.run(Thread.java:724)
> [2013-10-11 05:12:17,066] INFO Disconnecting from localhost:9093
> (kafka.producer.Syn
>
>                                                       cProducer)
> [2013-10-11 05:12:17,069] INFO Closing socket connection to /127.0.0.1.
> (kafka.netwo
>
>                                                 rk.Processor)
> [2013-10-11 05:12:17,099] WARN Error while fetching metadata    partition
> 0     lead
>
>                                               er: none        replicas:
>   isr:    isUnderReplicated: false for topic partition
>
>
>                [my-replicated-topic,0]: [class
> kafka.common.LeaderNotAvailableException] (kafka.pr
>
>
>             oducer.BrokerPartitionInfo)
> [2013-10-11 05:12:17,117] WARN Failed to collate messages by
> topic,partition due to:
>
>                                                            No leader for
> any partition in topic my-replicated-topic (kafka.producer.async.Defa
>
>
>                             ultEventHandler)

 
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