LrKafkaConsumer.beginningOffsets

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

public static Map<TopicPartition, Long> beginningOffsets(Collection<TopicPartition> partitions)

public static Map<TopicPartition, Long> beginningOffsets(Collection<TopicPartition> partitions, Duration timeout)

Arguments

NameDescription
partitionsCollection of partitions
timeoutTimeout limit, as a duration object

Return values

Returns the first offset for the given partitions.

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