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
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

 
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