Alphabetical List of Kafka Functions

Kafka protocol includes the following functions:

LrKafkaConsumer.closeConsumerCalls the close method on KafkaConsumer initialized for the Vuser and uninitializes it.
LrKafkaConsumer.<K, V>initConsumerInitializes a KafkaConsumer instance for the current Vuser.
LrKafkaConsumer.pollCalls the poll method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.pollForPolls topics for a set number of seconds and returns resulting ConsumerRecords.
LrKafkaConsumer.pollMinNoOfRecordsPolls until a minimum number of messages is received from the server, or maxNotFoundMessages polls return nothing.
LrKafkaConsumer.subscribeCalls the subscribe method on the KafkaConsumer initialized for the Vuser.
LrKafkaConsumer.unsubscribeCalls the unsubscribe method on the KafkaConsumer initialized for the Vuser.
LrKafkaProducer.beginTransactionCalls the beginTransaction method on the KafkaProducer initialized for the Vuser.
LrKafkaProducer.closeProducerCalls the close method on KafkaProducer initialized for the Vuser and uninitializes it.
LrKafkaProducer.<K, V>initProducerInitializes a KafkaProducer instance for the current Vuser.
LrKafkaProducer.initTransactionsCalls the initTransactions method on the KafkaProducer initialized for the Vuser.
LrKafkaProducer.sendCalls the send method on the KafkaProducer initialized for the Vuser.