Share this page

# Alphabetical List of Kafka Functions

Kafka protocol includes the following functions:

LrKafkaConsumer.assign | Calls the assign method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.assignment | Calls the assignment method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.beginningOffsets | Calls the beginningOffsets method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.closeConsumer | Calls the close method on KafkaConsumer initialized for the Vuser and uninitializes it.
LrKafkaConsumer.commitAsync | Calls the commitAsync method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.commitSync | Calls the commitSync method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.committed | Calls the committed method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.endOffsets | Calls the endOffsets method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.enforceRebalance | Calls the enforceRebalance method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.groupMetadata | Calls the groupMetadata method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.<K, V>initConsumer | Initializes a KafkaConsumer instance for the current Vuser.
LrKafkaConsumer.listTopics | Calls the listTopics method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.metrics | Calls the metrics method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.offsetsForTimes | Calls the offsetsForTimes method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.partitionsFor | Calls the partitionsFor method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.pause | Calls the pause method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.paused | Calls the paused method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.poll | Calls the poll method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.pollFor | Polls topics for a set number of seconds and returns resulting ConsumerRecords.
LrKafkaConsumer.pollMinNoOfRecords | Polls until a minimum number of messages is received from the server, or maxNotFoundMessages polls return nothing.
LrKafkaConsumer.position | Calls the position method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.reconfigureConsumer | Reconfigures the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.resume | Calls the resume method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.seek | Calls the seek method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.seekToBeginning | Calls the seekToBeginning method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.seekToEnd | Calls the seekToEnd method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.subscribe | Calls the subscribe method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.subscription | Calls the subscription method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.unsubscribe | Calls the unsubscribe method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.wakeup | Calls the wakeup method on the KafkaConsumer initialized for the Vuser.
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.

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