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 |
Return values
Returns the partitions for the given topic.
For more information about this function, see the Apache Kafka documentation.