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
