@Internal public final class PulsarConfigUtils extends Object
Configuration
.Modifier and Type | Method and Description |
---|---|
static org.apache.pulsar.client.admin.PulsarAdmin |
createAdmin(Configuration configuration)
PulsarAdmin shares almost the same configuration with PulsarClient, but we separate this
create method for directly create it.
|
static org.apache.pulsar.client.api.PulsarClient |
createClient(Configuration configuration)
Create a PulsarClient by using the flink Configuration and the config customizer.
|
static <F,T> T |
getOptionValue(Configuration configuration,
ConfigOption<F> option,
java.util.function.Function<F,T> convertor)
Get the option value str from given config, convert it into the real value instance.
|
static Map<String,String> |
getProperties(Configuration configuration,
ConfigOption<Map<String,String>> option)
Get the option value by a prefix.
|
static <T> void |
setOptionValue(Configuration configuration,
ConfigOption<T> option,
java.util.function.Consumer<T> setter)
Set the config option's value to a given builder.
|
static <T,V> void |
setOptionValue(Configuration configuration,
ConfigOption<T> option,
java.util.function.Function<T,V> convertor,
java.util.function.Consumer<V> setter)
Query the config option's value, convert it into a required type, set it to a given builder.
|
public static org.apache.pulsar.client.api.PulsarClient createClient(Configuration configuration)
public static org.apache.pulsar.client.admin.PulsarAdmin createAdmin(Configuration configuration)
public static <F,T> T getOptionValue(Configuration configuration, ConfigOption<F> option, java.util.function.Function<F,T> convertor)
public static <T> void setOptionValue(Configuration configuration, ConfigOption<T> option, java.util.function.Consumer<T> setter)
public static <T,V> void setOptionValue(Configuration configuration, ConfigOption<T> option, java.util.function.Function<T,V> convertor, java.util.function.Consumer<V> setter)
public static Map<String,String> getProperties(Configuration configuration, ConfigOption<Map<String,String>> option)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.