Uses of Class
com.hazelcast.jet.pulsar.PulsarConsumerBuilder

Packages that use PulsarConsumerBuilder

Package	Description
com.hazelcast.jet.pulsar	Contains a connector for Apache Pulsar which enables Hazelcast Jet pipelines to produce and consume messages on Pulsar topics.

Uses of PulsarConsumerBuilder in com.hazelcast.jet.pulsar

Methods in com.hazelcast.jet.pulsar that return PulsarConsumerBuilder

Modifier and Type	Method	Description
PulsarConsumerBuilder<M,T>	PulsarConsumerBuilder.batchReceivePolicySupplier(SupplierEx<org.apache.pulsar.client.api.BatchReceivePolicy> batchReceivePolicySupplier)
PulsarConsumerBuilder<M,T>	PulsarConsumerBuilder.consumerConfig(Map<String,Object> consumerConfig)
static <M, T> PulsarConsumerBuilder<M,T>	PulsarSources.pulsarConsumerBuilder(String topic, SupplierEx<org.apache.pulsar.client.api.PulsarClient> connectionSupplier, SupplierEx<org.apache.pulsar.client.api.Schema<M>> schemaSupplier, FunctionEx<org.apache.pulsar.client.api.Message<M>,T> projectionFn)	See the PulsarSources.pulsarConsumerBuilder(List, SupplierEx, SupplierEx, FunctionEx) It gets a single String for the topic name in case it should read only from a single topic.
static <M, T> PulsarConsumerBuilder<M,T>	PulsarSources.pulsarConsumerBuilder(List<String> topics, SupplierEx<org.apache.pulsar.client.api.PulsarClient> connectionSupplier, SupplierEx<org.apache.pulsar.client.api.Schema<M>> schemaSupplier, FunctionEx<org.apache.pulsar.client.api.Message<M>,T> projectionFn)	Returns a builder object that offers a step-by-step fluent API to build a custom Pulsar consumer StreamSource for the Pipeline API.