Share this page
LrKafkaConsumer.committed
Calls the committed method on the KafkaConsumer initialized for the Vuser.
public static Map<TopicPartition, OffsetAndMetadata> committed(Set<TopicPartition> partitions)
public static Map<TopicPartition, OffsetAndMetadata> committed(Set<TopicPartition> partitions, Duration timeout)
Arguments
| Name | Description |
|---|---|
| partitions | Collection of partitions |
| timeout | Timeout limit, as a duration object |
Return values
Returns the last committed offsets of the given partitions.
For more information about this function, see the Apache Kafka documentation.
