Oh, quick follow up I created a kafka-topics.bat and ran it and noticed
something hinke related to the topics description
[2013-06-27 10:04:17,066] INFO Starting ZkClient event thread.
(org.I0Itec.zkcli
ent.ZkEventThread)
[2013-06-27 10:04:17,068] INFO Opening socket connection to server
/10.0.1.10:21
81 (org.apache.zookeeper.ClientCnxn)
[2013-06-27 10:04:17,076] INFO Socket connection established to
10.0.1.10/10.0.1
.10:2181, initiating session (org.apache.zookeeper.ClientCnxn)
[2013-06-27 10:04:17,095] INFO Session establishment complete on server
10.0.1.1
0/10.0.1.10:2181, sessionid = 0x13f869505520003, negotiated timeout = 30000
(org
.apache.zookeeper.ClientCnxn)
[2013-06-27 10:04:17,101] INFO zookeeper state changed (SyncConnected)
(org.I0It
ec.zkclient.ZkClient)
blah
configs:
partitions: 1
partition 0
leader: 0 (10.0.1.10:9092)
replicas: 0 (10.0.1.10:9092)
isr: 0 (10.0.1.10:9092)
[2013-06-27 10:04:17,447] INFO Terminate ZkClient event thread.
(org.I0Itec.zkcl
ient.ZkEventThread)
[2013-06-27 10:04:17,458] INFO Session: 0x13f869505520003 closed
(org.apache.zoo
keeper.ZooKeeper)
[2013-06-27 10:04:17,461] INFO EventThread shut down
(org.apache.zookeeper.Clien
tCnxn)
I'm wondering why the leader and replicas have a 0 value as opposed to 1.
From: Denny Lee <denny.g....@gmail.com>
Date: Thursday, June 27, 2013 9:45 AM
To: "users@kafka.apache.org" <users@kafka.apache.org>
Cc: Denny Lee <denny.g....@gmail.com>
Subject: Re: Kafka 0.8 on Windows issues
Quick follow up this looks a lot like KAFKA-876
<https://issues.apache.org/jira/browse/KAFKA-876> so I'm trying that out
now.
From: Denny Lee <denny.g....@gmail.com>
Date: Thursday, June 27, 2013 9:10 AM
To: "users@kafka.apache.org" <users@kafka.apache.org>
Subject: Kafka 0.8 on Windows issues
While I was able to spin it up on OSX and Ubuntu without any issues, when
running this on Windows, I get the following error message when I execute
the consumer:
WARN
[console-consumer-8585_tardis8-1372348635138-29591e5d-leader-finder-thread],
Failed to add fetcher for [test,0] to broker id:0,host:10.0.1.10,port:9092
(kafka.consumer.ConsumerFetcherManager$$anon$1)
kafka.common.NotLeaderForPartitionException
The consumer console ends up pushing out a lot of messages to the console
where there is successful connection, fetching of metadata, the above
warning, and then shutting down the thread and stopping. Anyone else run
into a similar problem and by any chance have a solution?
The steps I had followed were:
- Grabbed the latest bits from github and ran sbt update, sbt package
- Updated the %\kafka\bin\windows batch files so that they were pointing to
the windows folder
- Executed windows\zookeeper-server-start.bat from the %\kafka\bin folder
- Executed windows\kafka-server-start.bat and
windows\kafka-console-producer.bat and they appear to look okay
- Then ran the windows\kafka-console-consumer.bat and it is apparent it is
not connecting properly
I've tried running this on Windows 8, Windows 2008 R2, and Windows 2012 as
well as tried using a standalone zookeeper 3.4.5 but with no luck.
Any ideas? Thanks in advance!
