How do we read Kafka topics in a given time range efficiently?
I need to read messages in given timerange from kafka topic. I have read docs, which says we can use offsetsForTimes
to get offset for a msg with earliest timestamp >= inputTimeStamp, and can start reading from there.