Hi, Everyone, I use the larger memory instance to replace that small one,
for now, I can create the topic, but when I try to produce message, it
still gives the same error.
Its so weird. can any one help me? Thanks
2013/10/10 Jiang Jacky <jiang0...@gmail.com>
> Another thing need is my instance comes with very small memory, just 683M,
> I am not sure if it is related. I will try to use 8G memory instance.
>
>
> 2013/10/10 Jiang Jacky <jiang0...@gmail.com>
>
>> yes, even I cannot create new topic, same error, leadernotavailable.
>> My zookeeper and storm all are working very well, except of Kafka.
>>
>>
>> 2013/10/10 Neha Narkhede <neha.narkh...@gmail.com>
>>
>>> Are you trying to produce these messages to a newly created topic?
>>>
>>>
>>> On Thu, Oct 10, 2013 at 6:15 PM, Jiang Jacky <jiang0...@gmail.com>
>>> wrote:
>>>
>>> > can anyone help me? Thanks a lot
>>> >
>>> >
>>> > 2013/10/10 Jiang Jacky <jiang0...@gmail.com>
>>> >
>>> > > Hi, I run into kafka issue recently, when I try to produce a
>>> message, it
>>> > > gives me follow error
>>> > >
>>> > > [2013-10-11 00:30:26,740] INFO Fetching metadata from broker
>>> > > id:0,host:localhost,port:9092 with correlation id 47 for 1 topic(s)
>>> > > Set(my-replicated-topic) (kafka.client.ClientUtils$)
>>> > > [2013-10-11 00:30:26,741] INFO Connected to localhost:9092 for
>>> producing
>>> > > (kafka.producer.SyncProducer)
>>> > > [2013-10-11 00:30:26,753] INFO Disconnecting from localhost:9092
>>> > > (kafka.producer.SyncProducer)
>>> > > [2013-10-11 00:30:26,753] INFO Closing socket connection to /
>>> 127.0.0.1.
>>> > > (kafka.network.Processor)
>>> > > [2013-10-11 00:30:26,754] WARN Error while fetching metadata
>>> > > [{TopicMetadata for topic my-replicated-topic ->
>>> > > No partition metadata for topic my-replicated-topic due to
>>> > > kafka.common.LeaderNotAvailableException}] for topic
>>> > [my-replicated-topic]:
>>> > > class kafka.common.LeaderNotAvailableException
>>> > > (kafka.producer.BrokerPartitionInfo)
>>> > > [2013-10-11 00:30:26,755] ERROR Failed to collate messages by topic,
>>> > > partition due to: Failed to fetch topic metadata for topic:
>>> > > my-replicated-topic (kafka.producer.async.DefaultEventHandler)
>>> > > [2013-10-11 00:30:26,755] INFO Back off for 100 ms before retrying
>>> send.
>>> > > Remaining retries = 0 (kafka.producer.async.DefaultEventHandler)
>>> > > [2013-10-11 00:30:26,856] INFO Fetching metadata from broker
>>> > > id:0,host:localhost,port:9092 with correlation id 48 for 1 topic(s)
>>> > > Set(my-replicated-topic) (kafka.client.ClientUtils$)
>>> > > [2013-10-11 00:30:26,857] INFO Connected to localhost:9092 for
>>> producing
>>> > > (kafka.producer.SyncProducer)
>>> > > [2013-10-11 00:30:26,874] INFO Disconnecting from localhost:9092
>>> > > (kafka.producer.SyncProducer)
>>> > > [2013-10-11 00:30:26,874] INFO Closing socket connection to /
>>> 127.0.0.1.
>>> > > (kafka.network.Processor)
>>> > > [2013-10-11 00:30:26,875] WARN Error while fetching metadata
>>> > > [{TopicMetadata for topic my-replicated-topic ->
>>> > > No partition metadata for topic my-replicated-topic due to
>>> > > kafka.common.LeaderNotAvailableException}] for topic
>>> > [my-replicated-topic]:
>>> > > class kafka.common.LeaderNotAvailableException
>>> > > (kafka.producer.BrokerPartitionInfo)
>>> > > [2013-10-11 00:30:26,876] ERROR Failed to send requests for topics
>>> > > my-replicated-topic with correlation ids in [41,48]
>>> > > (kafka.producer.async.DefaultEventHandler)
>>> > > [2013-10-11 00:30:26,876] 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)
>>> > >
>>> > >
>>> > > I have no idea why the leader is not available.Can someone give me a
>>> > hint?
>>> > > Thanks a lot.
>>> > >
>>> >
>>>
>>
>>
>
