Package com.hazelcast.jet.pulsar

Class PulsarDataConnection.Properties

java.lang.Object

com.hazelcast.jet.pulsar.PulsarDataConnection.Properties

Enclosing class:

PulsarDataConnection

public static final class PulsarDataConnection.Properties
extends Object

Properties that are possible to use with PulsarDataConnection.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BROKER_URL	Pulsar Broker URL.
static final String	ENABLE_TRANSACTIONS	If true, transactions will be activated on underlying PulsarClient.
static final String	HTTP_SERVICE_URL	Pulsar HTTP endpoint URL for administrative tasks, like listing resources or checking topic deduplication status.
static final String	NAMESPACE	Either localName ("namespace") or full name ("tenant/namespace").
static final String	TENANT	Tenant name, optional.

Constructor Summary

Constructors

Constructor	Description
Properties()

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

BROKER_URL

public static final String BROKER_URL

Pulsar Broker URL. Always mandatory.

See Also:

• Constant Field Values

HTTP_SERVICE_URL

public static final String HTTP_SERVICE_URL

Pulsar HTTP endpoint URL for administrative tasks, like listing resources or checking topic deduplication status.

See Also:

• Constant Field Values

NAMESPACE

public static final String NAMESPACE

Either localName ("namespace") or full name ("tenant/namespace"). Optional property. If set, it will filter only resources assigned to this namespace.

See Also:

• Constant Field Values

TENANT

public static final String TENANT

Tenant name, optional. If set, it will filter only resources assigned to this tenant.

See Also:

• Constant Field Values

ENABLE_TRANSACTIONS

public static final String ENABLE_TRANSACTIONS

If true, transactions will be activated on underlying PulsarClient. Please note, that transactions must be also enabled on broker side.

This option is necessary if given data connection will be used in Jet job with Pulsar Sink and ProcessingGuarantee.EXACTLY_ONCE processing guarantee.

See Also:

• Constant Field Values

Constructor Details

Properties

public Properties()