LrKafkaConsumer.seek
Calls the seek method on the KafkaConsumer initialized for the Vuser.
public static void seek(TopicPartition partition, long offset)
public static void seek(TopicPartition partition, OffsetAndMetadata offsetAndMetadata)
Arguments
Name | Description |
---|---|
partition | Topic partition that the seek will be performed on. |
offsets | Offset to be committed. |
offsetAndMetadata | An OffsetAndMetadata object representing the metadata. |
Return values
This function does not return any values.
General information
This function overrides the fetch offset that the consumer uses on the next poll.
For more information about this function, see the Apache Kafka documentation.