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

Switch to Plain View
Kafka, mail # user - Kafka cannot produce message


+
Jiang Jacky 2013-10-11, 00:33
+
Jiang Jacky 2013-10-11, 01:16
+
Neha Narkhede 2013-10-11, 01:34
+
Jiang Jacky 2013-10-11, 01:41
+
Jiang Jacky 2013-10-11, 01:42
+
Jiang Jacky 2013-10-11, 02:52
+
Aniket Bhatnagar 2013-10-11, 04:18
+
Jiang Jacky 2013-10-11, 04:39
+
Jun Rao 2013-10-11, 04:51
+
Jiang Jacky 2013-10-11, 04:57
+
Jun Rao 2013-10-11, 05:11
+
Jiang Jacky 2013-10-11, 05:21
+
Jun Rao 2013-10-11, 15:17
Copy link to this message
-
Re: Kafka cannot produce message
Neha Narkhede 2013-10-11, 16:06
Does the change to /etc/hosts resolve this issue as well?
On Fri, Oct 11, 2013 at 8:16 AM, Jun Rao <[EMAIL PROTECTED]> wrote:

> 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