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
Name | Description |
---|---|
offsets | Map of topic partitions and the respective offset metadata to be marked |
consumerGroupId | ID of the consumer group that will receive the offsets |
groupMetadata | Metadata 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.