LrKafkaConsumer.partitionsFor

Calls the partitionsFor method on the KafkaConsumer initialized for the Vuser.

public static List<PartitionInfo> partitionsFor(String topic)

public static List<PartitionInfo> partitionsFor(String topic, Duration timeout)

Arguments

Name	Description
topic	Name of the topic to which the partitions belong
timeout	Timeout limit, as a duration object

Returns the partitions for the given topic.

For more information about this function, see the Apache Kafka documentation.