Apache Kafka stores the message with offset. The following are several ways the messages can be retrieved with time;
...
--broker-list <hostname:port,..., REQUIRED: The list of hostname and hostname:port> port of the server to connect to.
--max-wait-ms <Integer: ms> The max amount of time each fetch request waits. (default: 1000)
--offsets <Integer: count> number of offsets returned (default: 1)
--partitions <partition ids> comma separated list of partition ids. If not specified, will find offsets for all partitions (default)
--time <Long: timestamp in milliseconds / -1(latest) / -2 (earliest) timestamp; offsets will come before this timestamp, as in getOffsetsBefore >
--topic <topic> REQUIRED: The topic to get offsets from.
...
Kafka Low Level Consumer API
For message partition reading, the kafka.api.OffsetRequest
class defines two constants: EarliestTime
and LatestTime
,
to find the beginning of the data in the logs and the new messages stream.