THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
/** * Look up the offsets for the given partitions by timestamp. The returned offset for each partition is the * earliest offset whose timestamp is greater than or equals to the given offsettimestamp in the corresponding partition. * * This is a blocking call. The consumer does not have to be assigned the partitions. * * @param timestampsToSearch the mapping from partition to the timestamp to look up. * @return For each partition, returns the timestamp and offset of the first message with timestamp greater * than or equal to the target timestamp. */ Map<TopicPartition, TimestampOffset> offsetForTime(Map<TopicPartition, Long> timestampsToSearch); |
...