LrKafkaConsumer.offsetsForTimes

Calls the offsetsForTimes method on the KafkaConsumer initialized for the Vuser.

public static Map<TopicPartition, OffsetAndTimestamp> offsetsForTimes(Map<TopicPartition, Long> timestampsToSearch)

public static Map<TopicPartition, OffsetAndTimestamp> offsetsForTimes(Map<TopicPartition, Long> timestampsToSearch, Duration timeout)

Arguments

NameDescription
timeStampsToSearchMap of partition and timestamps
timeoutTimeout limit, as a duration object

Return values

Returns the offsets for the given partitions by timestamp.

General information

This function looks up the offsets for the given partitions by timestamp.

For more information about this function, see the Apache Kafka documentation.