@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, but we separate this
creating method for directly use it.
|
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)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.