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

NameDescription
topic Name of the topic to which the partitions belong
timeoutTimeout limit, as a duration object

Return values

Returns the partitions for the given topic.

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