LrKafkaConsumer.assign
Calls the assign method on the KafkaConsumer initialized for the Vuser.
public static void assign(Collection<TopicPartition> partitions)
Arguments
Name | Description |
---|---|
partitions | Collection of partitions to be assigned to the consumer |
Return values
This function does not return any values.
General information
This function manually assigns a list of partitions to the consumer.
For more information about this function, see the Apache Kafka documentation.