Re: No Heartbeat request on commit

2016-04-28 Thread vinay sharma
I sent it as attachment. I did not zip it and may have been rejected by mail server. Will send again shortly. On Apr 28, 2016 5:11 PM, "Jason Gustafson" wrote: > Hey Vinay, > > Did you forget to attach the simple class? > > -Jason > > On Thu, Apr 28, 2016 at

Re: No Heartbeat request on commit

2016-04-28 Thread vinay sharma
I was also wondering that if commitSync acts as heartbeat then why do we still trigger heartbeat request on commit? why not just reset its time on successful commitSync? or am i wrong and we do this already? Regards, Vinay On Thu, Apr 28, 2016 at 3:38 PM, vinay sharma wrote: > Hi Ja

Re: No Heartbeat request on commit

2016-04-28 Thread vinay sharma
Hi Jason, Attached is a simple class with a main method. I used this for reproducing issue and generate logs that i attached earlier. This class has code snippets of poller relevant to the issue. Regards, Vinay Sharma On Thu, Apr 28, 2016 at 3:30 PM, Jason Gustafson wrote: > Hey Vi

Re: No Heartbeat request on commit

2016-04-28 Thread vinay sharma
on trunk, you'd have to upgrade the > brokers as well. Either that or you can rewind to before KAFKA-3306 (which > was just committed the day before yesterday)? > > -Jason > > On Thu, Apr 28, 2016 at 9:01 AM, vinay sharma > wrote: > > > Hi Jason, > > >

Re: No Heartbeat request on commit

2016-04-28 Thread vinay sharma
ol.types.Schema.read(Schema.java:75) at org.apache.kafka.clients.NetworkClient.parseResponse(NetworkClient.java:380) at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:449) Regards, Vinay Sharma On Thu, Apr 28, 2016 at 12:32 AM, Jason Gustafson wrote: > Hey Vinay,

Re: No Heartbeat request on commit

2016-04-27 Thread vinay sharma
does it mean that just the leader for partition of committed record knows that my consumer is alive and consumer's session on other brokers will still timeout? Regards, Vinay Sharma On Tue, Apr 26, 2016 at 2:38 PM, Jason Gustafson wrote: > Hey Vinay, > > Are you saying that heartbeat

Re: No Heartbeat request on commit

2016-04-26 Thread vinay sharma
successful but no heartbeat response received message in logs after meta refresh till next poll. Regards, Vinay Sharma On Mon, Apr 25, 2016 at 5:06 PM, Ismael Juma wrote: > Hi Vinay, > > This was fixed via https://issues.apache.org/jira/browse/KAFKA-3470 (will > be part of 0.10.0.0)

No Heartbeat request on commit

2016-04-25 Thread vinay sharma
seconds and 30 seconds is session time then i can see consumer getting timed out sometimes. Any help or pointers will be much appreciated. Thanks in advance. Regards, Vinay sharma