Share this page
Kafka Consumer Functions
Consumers are client applications that read events from Kafka. Kafka protocol includes the following consumer 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. |
