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 <yuanjia8...@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
