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


Copy link to this message
-
Re: LeaderNotAvailable Exception
Hi Neha,

Previously I have tried with trunk branch. After I have tried with 0.7
stable version. Now I am able to run some samples.

Thanks for your immediate responses.

I have only one small doubt. Can we set requests to be consumed by only one
consumer, means like a pull operation. Once consumed it shouldn't be
available for other consumers. Is this possible?

I am very new to kafka, that's why I am asking this.

Thanks in advance.

Thanks,
PrasannaKumar.
-----Original Message-----
From: Neha Narkhede
Sent: Thursday, January 24, 2013 10:46 AM
To: [EMAIL PROTECTED]
Subject: Re: LeaderNotAvailable Exception

That seems like a bug. Would you mind filing a JIRA and explaining your
test there so we can reproduce and fix the issue ?

Thanks,
Neha
On Wed, Jan 23, 2013 at 8:49 PM, Prasanna Kumar Jalakam <
[EMAIL PROTECTED]> wrote:

> Hi Neha,
>
> On zookeeper console it is appearing only once. But in Kafka - server
> console I am getting the following exception continuously when ever
> application tries to send some request.
>
> kafka.common.**LeaderNotAvailableException: Leader not local for topic
> test2 partition 0 on broker 0
>        at kafka.server.ReplicaManager.**getLeaderReplicaIfLocal(**
> ReplicaManager.scala:168)
>        at kafka.server.KafkaApis$$**anonfun$appendToLocalLog$2.**
> apply(KafkaApis.scala:271)
>        at kafka.server.KafkaApis$$**anonfun$appendToLocalLog$2.**
> apply(KafkaApis.scala:266)
>        at scala.collection.**TraversableLike$$anonfun$map$**
> 1.apply(TraversableLike.scala:**206)
>        at scala.collection.**TraversableLike$$anonfun$map$**
> 1.apply(TraversableLike.scala:**206)
>        at scala.collection.immutable.**Map$Map1.foreach(Map.scala:**105)
>
> Is this related to zookeeper or kafka? I am trying to electing leader
> manually but I am not able to do it.
>
> Any basic thing I am missing?
>
> Thanks
>
> Prasanna
>
>
> -----Original Message----- From: Neha Narkhede
> Sent: Thursday, January 24, 2013 10:10 AM
>
> To: [EMAIL PROTECTED]
> Subject: Re: LeaderNotAvailable Exception
>
> Prasanna,
>
> This log message is expected to appear once. Do you see it more than once
> in your logs ?
>
> Thanks,
> Neha
>
>
> On Wed, Jan 23, 2013 at 8:38 PM, Prasanna Kumar Jalakam <
> [EMAIL PROTECTED]> wrote:
>
>  Hi,
>>
>> I am running zookeeper in stand alone mode only. There is only partition
>> in there. So no chance for leader election. I am getting the following
>> error in zookeeper console.
>>
>> Got user-level KeeperException when processing
>> sessionid:0x13c6ace526d0000
>> type:create cxid:0x2c zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a
>> Error Path:/brokers/topics/test1/****partitions/0 Error:KeeperErrorCode =
>> NoNode for /brokers/topics/test1/****partitions/0
>> (org.apache.zookeeper.server.****PrepRequestProcessor)
>>
>>
>> Please help me to sort this out.
>>
>> Thanks,
>> Prasanna
>>
>> -----Original Message----- From: Neha Narkhede
>> Sent: Wednesday, January 23, 2013 10:07 PM
>> To: [EMAIL PROTECTED]
>> Subject: Re: LeaderNotAvailable Exception
>>
>>
>> That means the leader for partition [test, 0] is currently unavailable
>> and
>> ideally should be under another leader election. Do you see a lot of
>> these
>> errors ?
>>
>> Thanks,
>> Neha
>>
>>
>> On Wed, Jan 23, 2013 at 3:52 AM, Prasanna Kumar Jalakam <
>> [EMAIL PROTECTED]> wrote:
>>
>>  Hi All,
>>
>>>
>>> I am new to Apache Kafka. I am facing an issue while starting the
>>> producer.
>>>
>>> kafka.common.****LeaderNotAvailableException: Leader not local for topic
>>>
>>> test
>>> partition 0 on broker 0
>>>
>>>         at
>>> kafka.server.ReplicaManager.****getLeaderReplicaIfLocal(**
>>> ReplicaManager.scala:168)
>>>         at kafka.server.KafkaApis$$****anonfun$22.apply(KafkaApis.**
>>> scala:423)
>>>         at kafka.server.KafkaApis$$****anonfun$22.apply(KafkaApis.**
>>> scala:418)
>>>         at
>>> scala.collection.****TraversableLike$$anonfun$map$****
>>> 1.apply(TraversableLike.scala:****206)

 
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