Re: FetchRequestBuilder.maxWait: request for clarification

2014-10-19 Thread Jun Rao
Yes, your understanding is correct. For a long time, the implementation is buggy though. We fixed it (KAFKA-1430) in trunk a few months ago and the fix will be included in the 0.8.2 release. Thanks, Jun On Fri, Oct 17, 2014 at 5:44 AM, Magnus Vojbacke < magnus.vojba...@digitalroute.com> wrote:

FetchRequestBuilder.maxWait: request for clarification

2014-10-17 Thread Magnus Vojbacke
Hi, The method kafka.api.FetchRequestBuilder.maxWait(maxwait: Int) does not give the result I would have expected. I have not been able to find any documentation or clarification on the method’s meaning. My assumption is: If I send a fetch request for messages after offset X for a partition wh