Hi,

My usecase is to fetch the offsets for a given topic from X milliseconds ago.
If I use the offset api

https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-OffsetAPI

to do this and pass in a timestamp of (now() - X), I get the earliest offset in 
the current log segment and not the offset from X milliseconds ago.

Is this the correct usage or behaviour?

Thanks,
Manju

________________________________________________________________________
In order to protect our email recipients, Betfair Group use SkyScan from 
MessageLabs to scan all Incoming and Outgoing mail for viruses.

________________________________________________________________________

Reply via email to