ZkClient@13033a (org.apache.zookeeper.ZooKeeper)
> > > [2013-04-25 10:08:55,687] INFO Starting ZkClient event thread.
> > > (org.I0Itec.zkclient.ZkEventThread)
> > > [2013-04-25 10:08:55,687] INFO Opening socket connection to server
> > > localhost/127.0.0.1:2181 (org.apache.z
> > comm
>> > 1 ms (kafka.consumer.ZookeeperConsumerConnector)
>> > [2013-04-25 10:08:55,687] INFO Initiating client connection,
>> > connectString=localhost:2181 sessionTimeout=3000
>> > rg.I0Itec.zkclient.ZkClient@13033a (org.apache.zookeeper.ZooKeeper)
>> &
c in ZK
> > (kafka.consumer.ZookeeperConsumerConnector)
> > [2013-04-25 10:08:55,750] INFO
> > [console-consumer-70983_YIYIN-MAIN-1366909735562-a3d9410c], starting
> > watcher
> > e
> > ead for consumer console-consumer-70983_YIYIN-MAIN-1366909735562-a3d9410c
> &
o
> umerFetcherManager)
> [2013-04-25 10:08:55,969] INFO [ConsumerFetcherManager-1366909735672]
> Stopping all fetchers (kafka.consumer.C
> herManager)
> [2013-04-25 10:08:55,969] INFO [ConsumerFetcherManager-1366909735672] All
> connections stopped (kafka.consumer
> tcherMana
4] INFO
[console-consumer-70983_YIYIN-MAIN-1366909735562-a3d9410c], Not creating
event
r trivial whitelist test (kafka.consumer.ZookeeperConsumerConnector)
-Original Message-
From: Jun Rao [mailto:jun...@gmail.com]
Sent: Thursday, April 25, 2013 7:21 AM
To: users@kafka.apache.org
Subject: Re: Lea
oesn't show anything related to topic1> Date: Wed, 24 Apr 2013 20:58:09
> -0700
> > Subject: Re: LeaderNotAvailable Exception
> > From: jun...@gmail.com
> > To: users@kafka.apache.org
> >
> > What output do you get if you add the --unavailable-partitions o
With the option --unavailable-partitions --topic topic1, kafka-list-topic
doesn't show anything related to topic1> Date: Wed, 24 Apr 2013 20:58:09 -0700
> Subject: Re: LeaderNotAvailable Exception
> From: jun...@gmail.com
> To: users@kafka.apache.org
>
> What output do
hanged (SyncConnected) (org.I0Itec.zkclient.ZkClient)
> topic: topic1 partition: 0leader: 0 replicas: 0 isr: 0 >
> From: libo...@citi.com
> > To: users@kafka.apache.org
> > Subject: Re: LeaderNotAvailable Exception
> > Date: Wed, 24 Apr 2013 17:38:23 +
>
; Subject: Re: LeaderNotAvailable Exception
> Date: Wed, 24 Apr 2013 17:38:23 +
>
> Hi Jun,
>
> This exception also gave me a hard time. In my case, I didn't create the topic
> before using it for producing.
>
> Regards,
>
> Libo
>
Hi Jun,
This exception also gave me a hard time. In my case, I didn't create the topic
before using it for producing.
Regards,
Libo
Did you create the topic without a # of partitions then try to
delete/recreate it? I've had that happen to me before. Try shutting down
everything (including zookeeper) and restarting.
On Tue, Apr 23, 2013 at 9:08 PM, Jun Rao wrote:
> Does this happen on every message that you type in producer
Does this happen on every message that you type in producer console?
Thanks,
Jun
On Tue, Apr 23, 2013 at 4:15 PM, Yin Yin wrote:
> I tried to run the kafka 0.8 version as instructed in Quick Start. The
> kafka server shows the following message when I launch the producer. ERROR
> Error while
I tried to run the kafka 0.8 version as instructed in Quick Start. The kafka
server shows the following message when I launch the producer. ERROR Error
while fetching metadata for partition [test,0] (kafka.admin.AdminUtils$)
kafka.common.LeaderNotAvailableException: No leader exists for partitio
> 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?
It seems you want the data in a topic to be consumed by multiple consumers
in a mutually exclusiv
ubject: 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 <
prasann...@imimobile.com> wrote:
Hi Neha,
On zookeep
ookeeper 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: users@ka
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: users@kafka.apache.org
Subject: Re: LeaderNotAvailable Exception
Prasanna,
This log message is expected to appear once. Do you
ede
> Sent: Wednesday, January 23, 2013 10:07 PM
> To: users@kafka.apache.org
> 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
&g
Narkhede
Sent: Wednesday, January 23, 2013 10:07 PM
To: users@kafka.apache.org
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
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 <
prasann...@imimobile.com> wrote:
> Hi All,
>
> I am new to Apache
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
21 matches
Mail list logo
