Re: potential bug with offset request and just rolled log segment

2015-06-03 Thread Guozhang Wang
Alfred, As for 0.8.3, we are shooting for end of July: https://cwiki.apache.org/confluence/display/KAFKA/Future+release+plan Guozhang On Tue, Jun 2, 2015 at 8:43 AM, Alfred Landrum alf...@jut.io wrote: I filed KAFKA-2236: https://issues.apache.org/jira/browse/KAFKA-2236 Is there any

Re: potential bug with offset request and just rolled log segment

2015-06-02 Thread Alfred Landrum
I filed KAFKA-2236: https://issues.apache.org/jira/browse/KAFKA-2236 Is there any guidance on when 0.8.3 might be released?

potential bug with offset request and just rolled log segment

2015-06-01 Thread Alfred Landrum
I'm running 0.8.2 in a setup that's rolling segments relatively often. Using my non-Kafka client that's using librdkafka, I occasionally see this in my kafka logs: ... [2015-05-30 00:30:26,149] INFO Rolled new log segment for 'receiver-db1fc9b7-85b2-4016-8eda-66a356cb2ae8-35' in 1 ms.

Re: potential bug with offset request and just rolled log segment

2015-06-01 Thread Guozhang Wang
Hi Alfred, I check the 0.8.2 code and may probably find a bug related to your issue. Basically, segsArray.last.size is called multiple times during handling offset requests, while segsArray.last could get concurrent appends. Hence it is possible that in line 461, if(segsArray.last.size 0)