kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Manikumar Reddy <ku...@nmsworks.co.in>
Subject Re: Pagecache cause OffsetOutOfRangeException
Date Tue, 02 Dec 2014 15:50:21 GMT
You can check the latest/earliest offsets of a given topic by running
GetOffsetShell.

https://cwiki.apache.org/confluence/display/KAFKA/System+Tools#SystemTools-GetOffsetShell

On Tue, Dec 2, 2014 at 2:05 PM, yuanjia8947 <yuanjia8947@163.com> wrote:

> Hi all,
> I'm using kafka 0.8.0 release now. And I often encounter the problem
> OffsetOutOfRangeException when cosuming message by simple consumer API.
> But I'm sure that the consuming offset is smaller than the latest offset
> got from OffsetRequest.
> Can it be caused by that new messages are wrote to kernel's pagecache and
> not flush to the file yet,
> while I'm consuming new messages from the file?
> How fix it?
>
> Thanks,
> liyuanjia
>
>
>
>
>
> liyuanjia

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message