LrKafkaConsumer.subscribe
Calls the subscribe method on the KafkaConsumer initialized for the Vuser.
public static void subscribe(Pattern pattern, ConsumerRebalanceListener listener)
public static void subscribe(Pattern pattern)
public static void subscribe(Collection<String> topics)
public static void subscribe(Collection<String> topics, ConsumerRebalanceListener listener)
Arguments
Name | Description |
---|---|
pattern | Pattern for matching the topics that the consumer listens for |
listener | Non-null listener instance to receive notifications on partition assignment/revocation for the subscribed topics |
topics | Collection of topics to listen to |
Return values
This function does not return any values.
General information
This function allows you to subscribe to a pattern, topic, or list of topics found on the Kafka broker.
For more information about this function, see the Apache Kafka documentation.