Package org.springframework.pulsar.core

Class DefaultPulsarReaderFactory<T>

java.lang.Object

org.springframework.pulsar.core.DefaultPulsarReaderFactory<T>

Type Parameters:

T - message type

All Implemented Interfaces:

PulsarReaderFactory<T>

public class DefaultPulsarReaderFactory<T>
extends Object
implements PulsarReaderFactory<T>

Default implementation of PulsarReaderFactory.

Author:

Soby Chacko

Constructor Summary

Constructors

Constructor	Description
DefaultPulsarReaderFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient)	Construct a reader factory instance with no default configuration.
DefaultPulsarReaderFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, List<ReaderBuilderCustomizer<T>> defaultConfigCustomizers)	Construct a reader factory instance.

Method Summary

Modifier and Type	Method	Description
org.apache.pulsar.client.api.Reader<T>	createReader(List<String> topics, org.apache.pulsar.client.api.MessageId messageId, org.apache.pulsar.client.api.Schema<T> schema, List<ReaderBuilderCustomizer<T>> customizers)	Creating a Pulsar Reader based on the provided topics, schema and properties.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultPulsarReaderFactory

public DefaultPulsarReaderFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient)

Construct a reader factory instance with no default configuration.

Parameters:

pulsarClient - the client used to consume

DefaultPulsarReaderFactory

public DefaultPulsarReaderFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient,
 @Nullable
 List<ReaderBuilderCustomizer<T>> defaultConfigCustomizers)

Construct a reader factory instance.

Parameters:

pulsarClient - the client used to consume

defaultConfigCustomizers - the optional list of customizers to apply to the readers or null to use no default configuration

Method Details

createReader

public org.apache.pulsar.client.api.Reader<T> createReader(@Nullable
 List<String> topics,
 @Nullable
 org.apache.pulsar.client.api.MessageId messageId,
 org.apache.pulsar.client.api.Schema<T> schema,
 @Nullable
 List<ReaderBuilderCustomizer<T>> customizers)
                                                    throws org.apache.pulsar.client.api.PulsarClientException

Description copied from interface: PulsarReaderFactory

Creating a Pulsar Reader based on the provided topics, schema and properties.

Specified by:

createReader in interface PulsarReaderFactory<T>

Parameters:

topics - set of topics to read from

messageId - starting message id to read from

schema - schema of the message to consume

customizers - the optional list of customizers to apply to the reader builder. Note that the customizers are applied last and have the potential for overriding any specified parameters or default properties.

Returns:

Pulsar Reader

Throws:

org.apache.pulsar.client.api.PulsarClientException - if there are issues when creating the reader