@Internal public final class PulsarClientFactory extends Object
PulsarConfiguration
.Modifier and Type | Method and Description |
---|---|
static org.apache.pulsar.client.admin.PulsarAdmin |
createAdmin(PulsarConfiguration configuration)
PulsarAdmin shares almost the same configuration with PulsarClient, we use this creating
method for creating PulsarAdmin instead of using
ClientConfigurationData . |
static org.apache.pulsar.client.api.PulsarClient |
createClient(PulsarConfiguration configuration)
Create a PulsarClient by using the flink Configuration and the config customizer.
|
public static org.apache.pulsar.client.api.PulsarClient createClient(PulsarConfiguration configuration)
public static org.apache.pulsar.client.admin.PulsarAdmin createAdmin(PulsarConfiguration configuration)
ClientConfigurationData
.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.