Class PulsarClientConfig

java.lang.Object

io.numaproj.pulsar.config.client.PulsarClientConfig

public final class PulsarClientConfig
extends Object

Builds a PulsarClient from configuration.

Method Summary

Modifier and Type	Method	Description
static org.apache.pulsar.client.api.PulsarClient	create(PulsarClientProperties pulsarClientProperties)	Builds a PulsarClient from the supplied client properties.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

create

public static org.apache.pulsar.client.api.PulsarClient create(PulsarClientProperties pulsarClientProperties)
                                                        throws org.apache.pulsar.client.api.PulsarClientException

Builds a PulsarClient from the supplied client properties.

Parameters:

pulsarClientProperties - parsed pulsar.client config

Returns:

the Pulsar client

Throws:

org.apache.pulsar.client.api.PulsarClientException - if the client cannot be built