This gives you back two valid offsets, not a range. Thanks,
Jun On Fri, May 24, 2013 at 11:29 AM, Sining Ma <sinin...@aol.com> wrote: > Hi, > We are currently using kafka-0.7.1 right now. > I have two questions: > 1. We use SimpleConsumer to aggregate messages to log files and there is > no zookeeper. Sometimes we can see kafka.common.OffsetOutOfRangeException. > And this exception happens when we start our consumer program. We do not > know the reason why this happens. > How can I get a valid latest message offset in kafka-0.7.1 when this > exception happens? > 2. Before we start consumer, we call getOffsetsBefore function to get a > list of valid offsets (up to maxSize) before the given time. > How can we interpret this list? > For example, this function returns an array [offset1, offset2]. > Does this mean from offset1 to offset2 are valid, and offset2 to current > offset are valid? We are confused about the meaning of this array. > > > > -- Regards > Sining Ma > > >
