Package com.hazelcast.jet.pulsar

Class PulsarDataConnection

java.lang.Object

com.hazelcast.dataconnection.DataConnectionBase

com.hazelcast.jet.pulsar.PulsarDataConnection

All Implemented Interfaces:

DataConnection

public class PulsarDataConnection
extends DataConnectionBase

Represents Apache Pulsar DataConnection.

Since:

6.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	PulsarDataConnection.Properties	Properties that are possible to use with PulsarDataConnection.

Constructor Summary

Constructors

Constructor	Description
PulsarDataConnection(DataConnectionConfig config)

Method Summary

Modifier and Type	Method	Description
void	destroy()	Called by the member when shutting down.
org.apache.pulsar.client.admin.PulsarAdmin	getAdmin()
org.apache.pulsar.client.api.PulsarClient	getClient()	Creates a new client or reuses shared one.
Collection<DataConnectionResource>	listResources()	Lists all resources, filtering out by tenant and/or namespace if specified.
static DataConnectionConfig	pulsarDataConnectionConf(String name, String brokerUrl, String serviceHttpUrl)	Returns basic DataConnectionConfig with given name, brokerUrl and service url.
static DataConnectionConfig	pulsarDataConnectionConf(String name, String brokerUrl, String serviceHttpUrl, boolean enableTransactions)	Returns basic DataConnectionConfig with given name, brokerUrl and service url and transactions activated/deactivated.
Collection<String>	resourceTypes()	Returns the list of possible values for DataConnectionResource.type(), that will be returned when DataConnection.listResources() is called.

Methods inherited from class com.hazelcast.dataconnection.DataConnectionBase

getConfig, getName, release, retain

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.dataconnection.DataConnection

options

Constructor Details

PulsarDataConnection

public PulsarDataConnection(DataConnectionConfig config)

Method Details

getClient

@Nonnull
public org.apache.pulsar.client.api.PulsarClient getClient()

Creates a new client or reuses shared one.

In case of shared data connections, the DataConnectionBase.retain() method is always automatically called. If there is an error during client creation, the data connection is not released and DataConnectionBase.release() must be called explicitly.

getAdmin

public org.apache.pulsar.client.admin.PulsarAdmin getAdmin()

listResources

@Nonnull
public Collection<DataConnectionResource> listResources()

Lists all resources, filtering out by tenant and/or namespace if specified.

resourceTypes

@Nonnull
public Collection<String> resourceTypes()

Description copied from interface: DataConnection

Returns the list of possible values for DataConnectionResource.type(), that will be returned when DataConnection.listResources() is called. Returned values are case-insensitive, e.g. DataConnectionResource.type() may return MY_RES and this method my_res.

destroy

public void destroy()

Description copied from interface: DataConnection

Called by the member when shutting down. Should unconditionally close all connections and release resources.

pulsarDataConnectionConf

@Nonnull
public static DataConnectionConfig pulsarDataConnectionConf(@Nonnull
 String name,
 @Nonnull
 String brokerUrl,
 @Nullable
 String serviceHttpUrl)

Returns basic DataConnectionConfig with given name, brokerUrl and service url.

pulsarDataConnectionConf

@Nonnull
public static DataConnectionConfig pulsarDataConnectionConf(@Nonnull
 String name,
 @Nonnull
 String brokerUrl,
 @Nullable
 String serviceHttpUrl,
 boolean enableTransactions)

Returns basic DataConnectionConfig with given name, brokerUrl and service url and transactions activated/deactivated.