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

2015-06-02 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 wrote: > I filed KAFKA-2236: > https://issues.apache.org/jira/browse/KAFKA-2236 > > Is there any guidance on whe

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?

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

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. (kafka.log.L