Kafka Consumer Functions

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