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.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. |
