LrKafkaConsumer.commitAsync

Calls the commitAsync method on the KafkaConsumer initialized for the Vuser.

public static void commitAsync()

public static void commitAsync(OffsetCommitCallback callback)

public static void commitAsync(Map<TopicPartition, OffsetAndMetadata> offsets, OffsetCommitCallback callback)

Arguments

Name	Description
timeout	Timeout for commitAsync, as a duration
offsets	Map of partitions and their respective offsets to be committed. If this is not specified, the function commits offsets returned on the last poll for the entire subscribed list of topics and partitions asynchronously.

This function does not return any values.

For more information about this function, see the Apache Kafka documentation.