My question is, am I understanding the meaning of "Time" right? Or should I try other values for the "Time" field? Thanks for your time!
The time field expects an absolute unix timestamp, except for the 2 special values for getting earliest and latest offsets. Thanks Neha On Thursday, March 13, 2014, Churu Tang <ct...@rubiconproject.com> wrote: > Hi, > I am building kafka client using C++ Client API. The offsetRequest API is > based on > > https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-OffsetRequest > > According to the documentation, the "Time" field in offsetRequest is used > to ask for all messages before a certain time (ms), special value are -1 > and -2. So my understanding is, if I put "1" in the "Time" field, all > offsets 1 ms ago should be retrieved. If there are 6 messages published to > the partition between 1 hour ago and now(the kafka-console-consumer.sh and > c++ fetchRequest are able to see those 6 messages), then I should be able > to get all of those offsets. But when I tried to use 1, 10, 1000, 10000 and > current epoch time as "Time" , none of those will return any offset. > > My question is, am I understanding the meaning of "Time" right? Or should > I try other values for the "Time" field? Thanks for your time! > > Cheers, > Churu
