able on the partition. Why would you need it to?
>
> On Mon, Apr 20, 2015 at 3:46 AM, Alexey Borschenko
> wrote:
> >> You can also send a FetchOffsetRequest and check for the last
> >> available offset (log end offset) - this way you won't have to send a
> >> fet
Does *SimpleConsumer.getOffsetsBefore* takes in account consumer group
specific offsets?
I need to be able to get offsets closest to specified timestamp per
topic-consumerGroup.
Is there any way to achieve this using Kafka API ?
Thanx!
> You can also send a FetchOffsetRequest and check for the last
> available offset (log end offset) - this way you won't have to send a
> fetch request that is likely to fail.
Does this takes in account specific consumer offsets stored in Zookeeper?
On Fri, Apr 17, 2015 at 5:57 PM, Gwen Shapira
Hi all!
I need to read offsets closing to specified timestamp.
As I can see this can be achieved by using SImpleConsumer API.
To test things I use SimpleConsumer example provided on site:
https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example
I use Kafka 8.2.1
When I pass