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)}
PulsarReaderBuilder<M,T>	See PulsarSources.pulsarReaderBuilder(String, SupplierEx, SupplierEx, FunctionEx)
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.