Modifier and Type | Method and Description |
---|---|
static void |
checkConfigurations(Configuration configuration)
Helper method for checking client related config options.
|
static <T> org.apache.pulsar.client.api.ConsumerBuilder<T> |
createConsumerBuilder(org.apache.pulsar.client.api.PulsarClient client,
org.apache.pulsar.client.api.Schema<T> schema,
Configuration configuration)
Create a pulsar consumer builder by using the given Configuration.
|
public static void checkConfigurations(Configuration configuration)
public static <T> org.apache.pulsar.client.api.ConsumerBuilder<T> createConsumerBuilder(org.apache.pulsar.client.api.PulsarClient client, org.apache.pulsar.client.api.Schema<T> schema, Configuration configuration)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.