LrKafkaConsumer.endOffsets

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

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

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

Arguments

NameDescription
partitionsCollection of partitions
timeoutTimeout limit, as a duration object

Return values

Returns the end offset for the given partitions.

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