Package com.hazelcast.jet.pulsar

package com.hazelcast.jet.pulsar

Contains a connector for Apache Pulsar which enables Hazelcast Jet pipelines to produce and consume messages on Pulsar topics.

Related Packages

Package	Description
com.hazelcast.jet	Hazelcast Jet is a distributed computation engine running on top of Hazelcast IMDG technology.

Classes

Class	Description
PulsarConsumerBuilder<M,T>	See PulsarSources.pulsarConsumerBuilder(List, SupplierEx, SupplierEx, FunctionEx)}
PulsarDataConnection	Represents Apache Pulsar DataConnection.
PulsarDataConnection.Properties	Properties that are possible to use with PulsarDataConnection.
PulsarDataConnectionRegistration	Registers PulsarDataConnection.
PulsarReaderBuilder<M,T>	See PulsarSources.pulsarReaderBuilder(String, SupplierEx, SupplierEx, FunctionEx)
PulsarSchema<E>	Helper class that holds context info about Pulsar's Schema, without using Pulsar API directly.
PulsarSinkBuilder<E,M>	See PulsarSinks.builder(String, SupplierEx, SupplierEx, FunctionEx)
PulsarSinks	Contains factory methods for Pulsar sinks.
PulsarSources	Contains builders for creating Pulsar stream sources.