Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> OffsetOutOfRangeException and getOffsetsBefore

Copy link to this message
Re: OffsetOutOfRangeException and getOffsetsBefore
This gives you back two valid offsets, not a range.


On Fri, May 24, 2013 at 11:29 AM, Sining Ma <[EMAIL PROTECTED]> 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