Share this page

# Kafka Producer Functions

Producers are client applications that publish events to Kafka. Kafka protocol includes the following producer functions:

LrKafkaProducer.abortTransaction | Calls the abortTransaction method on the KafkaProducer initialized for the Vuser.
LrKafkaProducer.beginTransaction | Calls the beginTransaction method on the KafkaProducer initialized for the Vuser.
LrKafkaProducer.closeProducer | Calls the close method on KafkaProducer initialized for the Vuser and uninitializes it.
LrKafkaProducer.commitTransaction | Calls the commitTransaction method on the KafkaProducer initialized for the Vuser.
LrKafkaProducer.flush | Calls the flush method on the KafkaProducer initialized for the Vuser.
LrKafkaProducer.<K, V>initProducer | Initializes a KafkaProducer instance for the current Vuser.
LrKafkaProducer.initTransactions | Calls the initTransactions method on the KafkaProducer initialized for the Vuser.
LrKafkaProducer.metrics | Calls the metrics method on the KafkaProducer initialized for the Vuser.
LrKafkaProducer.newRecord | A fluent Builder pattern API for constructing producer records.
LrKafkaProducer.partitionsFor | Calls the partitionsFor method on the KafkaProducer initialized for the Vuser.
LrKafkaProducer.reconfigureProducer | Reconfigures the KafkaProducer initialized for the Vuser.
LrKafkaProducer.send | Calls the send method on the KafkaProducer initialized for the Vuser.
LrKafkaProducer.sendOffsetsToTransaction | Calls the sendOffsetsToTransaction method on the KafkaProducer initialized for the Vuser.

Tips to improve your search results... VuGen Function Reference Version 26.1-26.3 Function Reference 26.1-26.3 All View Local Help Center View Online Help Center Version: