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
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
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
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,
> >
>
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,
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
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)
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