Re: Producer waiting ~15 mins before disconnecting.

loss on idle connections. (as a positive side effect it also helps keeping connections alive through NAT/firewalls/LBs) If this is not available in the client in question I suggest you file an issue (JIRA). Regards, Magnus 2015-05-19 21:38 GMT+02:00 4mayank 4may...@gmail.com: I am using

Producer waiting ~15 mins before disconnecting.

I am using kafka 0.8.2.1 old producer. When one of the kafka node in the remote cluster is down the producer is waiting about 15 minutes before it disconnects and tries to connect to another node. (kafka takes 1 min to change leaders). Producer config used: request.required.acks=1

Re: Consumer offsets in offsets topic 0.8.2

has been committed. It will throw ZK exception, which is very confusing. KAFKA-1951 was opened for this but was not checked in. Thanks. Jiangjie (Becket) Qin On 4/13/15, 9:55 AM, 4mayank 4may...@gmail.com wrote: I did a similar change - moved from High Level Consumer to Simple Consumer

Re: Consumer offsets in offsets topic 0.8.2

I did a similar change - moved from High Level Consumer to Simple Consumer. Howerver kafka-consumer-offset-checker.sh throws an exception. Its searching the zk path /consumers/group/ which does not exist on any of my zk nodes. Is there any other tool for getting the offset lag when using Simple

Re: java api code and javadoc

https://github.com/apache/kafka#building-javadocs-and-scaladocs From: 4mayank 4may...@gmail.com Sent: Wednesday, October 15, 2014 11:38 AM To: users@kafka.apache.org Subject: java api code and javadoc Hi I downloaded kafka 0.8.1.1 src and went through

java api code and javadoc

Hi I downloaded kafka 0.8.1.1 src and went through some documentation and wikis, but could not find any documentation (javadoc or other) on the java API - info on classes like SimpleConsumer, MessageAndOffset etc. Nor could I locate the source code (.java). I see only scala files. Can anyone