LrKafkaConsumer.listTopics
Calls the listTopics method on the KafkaConsumer initialized for the Vuser.
public static Map<String, List<PartitionInfo>> listTopics()
public static Map<String, List<PartitionInfo>> listTopics(Duration timeout)
Arguments
Name | Description |
---|---|
timeout | Timeout limit, as a duration object |
Return values
Returns metadata about partitions for all topics that the user is authorized to view.
For more information about this function, see the Apache Kafka documentation.