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
Name | Description |
---|---|
partitions | Collection of partitions |
timeout | Timeout 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.