LrKafkaConsumer.position
Calls the position method on the KafkaConsumer initialized for the Vuser.
public static long position(TopicPartition partition)
public static long position(TopicPartition partition, Duration timeout)
Arguments
Name | Description |
---|---|
partition | Partition on which the seek is performed |
timeout | Timeout limit, as a duration object |
Return values
Returns the offset of the next record that will be fetched of the given partition.
For more information about this function, see the Apache Kafka documentation.