LrKafkaProducer.sendOffsetsToTransaction

Calls the sendOffsetsToTransaction method on the KafkaProducer initialized for the Vuser.

public static void sendOffsetToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets, String consumerGroupId) throws ProducerFencedException

public static void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets, ConsumerGroupMetadata groupMetadata) throws ProducerFencedException

Arguments

NameDescription
offsetsMap of topic partitions and the respective offset metadata to be marked
consumerGroupIdID of the consumer group that will receive the offsets
groupMetadataMetadata of the consumer group that will receive the offsets

Return Values

This function does not return any values.

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