Re: kafka.common.LeaderNotAvailableException

This worked. Thank you. > On Jun 25, 2014, at 7:04 AM, Joe Stein wrote: > > Zach, that error will occur if different brokers are advertising themselves > in such a way where they are resolving to the same IP address. The > advertised hostname is the hostname that will be given out to producers

Re: kafka.common.LeaderNotAvailableException

Zach, that error will occur if different brokers are advertising themselves in such a way where they are resolving to the same IP address. The advertised hostname is the hostname that will be given out to producers, consumers, and other brokers to connect to from the fetch meta data request. Chec

Re: kafka.common.LeaderNotAvailableException

server.log has a lot of these errors: [2014-06-24 20:07:16,124] ERROR [KafkaApi-6] error when handling request Name: FetchRequest; Version: 0; CorrelationId: 81138; ClientId: ReplicaFetche rThread-0-5; ReplicaId: 6; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [test1,0] -> PartitionFetchInfo(0,

Re: kafka.common.LeaderNotAvailableException

Are there any errors in the broker's logs? /*** Joe Stein Founder, Principal Consultant Big Data Open Source Security LLC http://www.stealth.ly Twitter: @allthingshadoop **

Re: kafka.common.LeaderNotAvailableException

BTW I think it is better if we can make such logging entries as WARN for the first few times, since they are not really ERRORs. Guozhang On Sun, Mar 23, 2014 at 10:33 AM, Guozhang Wang wrote: > Hi Robert, > > This error is expected on the first few messages sending with a new topic, > since th

Re: kafka.common.LeaderNotAvailableException

Hi Robert, This error is expected on the first few messages sending with a new topic, since the broker needs some time to create the topic and propagate the metadata. Please try keep sending and see if this exception goes away. If it is not transient, please let us know. Guozhang On Fri, Mar 21

Re: kafka.common.LeaderNotAvailableException

I've found the response to my own question: http://mail-archives.apache.org/mod_mbox/kafka-users/201308.mbox/%3c44d1e1522419a14482f89ff4ce322ede25025...@brn1wnexmbx01.vcorp.ad.vrsn.com%3E On Wed, Jan 29, 2014 at 1:17 PM, Gerrit Jansen van Vuuren < gerrit...@gmail.com> wrote: > Hi, > > I'm testi

Re: kafka.common.LeaderNotAvailableException: No leader for any partition

thanks so much to both of you guys. Looks like its working using your test clients. On Thu, May 30, 2013 at 1:57 PM, Neha Narkhede wrote: > Can you check if the value for zookeeper.connect is set correctly ? We > changed the name of some configs in 08, you can find the new config names > here -

Re: kafka.common.LeaderNotAvailableException: No leader for any partition

Can you check if the value for zookeeper.connect is set correctly ? We changed the name of some configs in 08, you can find the new config names here - http://kafka.apache.org/08/configuration.html Thanks, Neha On Thu, May 30, 2013 at 1:33 PM, Vadim Keylis wrote: > Your advice is appreciated >

Re: kafka.common.LeaderNotAvailableException: No leader for any partition

Your advice is appreciated On Thu, May 30, 2013 at 1:32 PM, Vadim Keylis wrote: > Jun. > I rebuilt kafka this morning by following this steps > > > git clone https://git-wip-us.apache.org/repos/asf/kafka.git> cd kafka > > git checkout -b 0.8 remotes/origin/0.8 > > ./sbt update > > ./sbt +packag

Re: kafka.common.LeaderNotAvailableException: No leader for any partition

Jun. I rebuilt kafka this morning by following this steps > git clone https://git-wip-us.apache.org/repos/asf/kafka.git> cd kafka > git checkout -b 0.8 remotes/origin/0.8 > ./sbt update > ./sbt +package > ./sbt +assembly-package-dependency deployed to jar files kafka_2.9.2-0.8.0-SNAPSHOT.jar kaf

Re: kafka.common.LeaderNotAvailableException: No leader for any partition

Are you using the latest code from the 0.8 branch? Any exception/error in the broker log (including state-change.log)? Thanks, Jun On Wed, May 29, 2013 at 10:49 PM, Vadim Keylis wrote: > I am working on deploying Kafka 0.8 to our test cluster that consist of 2 > kafka servers and 2 zookeper no