This gives you back two valid offsets, not a range.
Thanks,
Jun
On Fri, May 24, 2013 at 11:29 AM, Sining Ma 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
> OffsetRequest?
> Could you give me an example for this API?
>
>
>
> -- Regards
> Sining Ma
>
>
>
>
>
> -Original Message-
> From: Suyog Rao
> To: users
> Sent: Fri, May 24, 2013 1:32 pm
> Subject: Re: OffsetOutOfRangeExc
?
-- Regards
Sining Ma
-Original Message-
From: Suyog Rao
To: users
Sent: Fri, May 24, 2013 1:32 pm
Subject: Re: OffsetOutOfRangeException and getOffsetsBefore
Since you are using the simple consumer you will need to handle the
OffsetOutOfRange Exception in your code. This
Since you are using the simple consumer you will need to handle the
OffsetOutOfRange Exception in your code. This happens when your consumer
queries for an offset which is no longer persisted in Kafka (The logs have been
deleted based on the retention policy). Ideally when this happens, the cons
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
