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

NameDescription
partitionPartition on which the seek is performed
timeoutTimeout 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.