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

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.