Class SubscriberBuilder.Builder (1.6.3)

Stay organized with collections Save and categorize content based on your preferences.
public abstract static class SubscriberBuilder.Builder

Inheritance

java.lang.Object > SubscriberBuilder.Builder

Constructors

Builder()

public Builder()

Methods

build()

public Subscriber build()
Returns
TypeDescription
Subscriber
Exceptions
TypeDescription
ApiException

setInitialLocation(SeekRequest initialLocation)

public abstract SubscriberBuilder.Builder setInitialLocation(SeekRequest initialLocation)
Parameter
NameDescription
initialLocationSeekRequest
Returns
TypeDescription
SubscriberBuilder.Builder

setMessageConsumer(Consumer<List<SequencedMessage>> messageConsumer)

public abstract SubscriberBuilder.Builder setMessageConsumer(Consumer<List<SequencedMessage>> messageConsumer)
Parameter
NameDescription
messageConsumerConsumer<List<SequencedMessage>>
Returns
TypeDescription
SubscriberBuilder.Builder

setPartition(Partition partition)

public abstract SubscriberBuilder.Builder setPartition(Partition partition)
Parameter
NameDescription
partitionPartition
Returns
TypeDescription
SubscriberBuilder.Builder

setResetHandler(SubscriberResetHandler resetHandler)

public abstract SubscriberBuilder.Builder setResetHandler(SubscriberResetHandler resetHandler)
Parameter
NameDescription
resetHandlerSubscriberResetHandler
Returns
TypeDescription
SubscriberBuilder.Builder

setRetryStreamRaces(boolean retryStreamRaces)

public abstract SubscriberBuilder.Builder setRetryStreamRaces(boolean retryStreamRaces)
Parameter
NameDescription
retryStreamRacesboolean
Returns
TypeDescription
SubscriberBuilder.Builder

setStreamFactory(StreamFactories.SubscribeStreamFactory streamFactory)

public abstract SubscriberBuilder.Builder setStreamFactory(StreamFactories.SubscribeStreamFactory streamFactory)
Parameter
NameDescription
streamFactoryStreamFactories.SubscribeStreamFactory
Returns
TypeDescription
SubscriberBuilder.Builder

setSubscriptionPath(SubscriptionPath path)

public abstract SubscriberBuilder.Builder setSubscriptionPath(SubscriptionPath path)
Parameter
NameDescription
pathSubscriptionPath
Returns
TypeDescription
SubscriberBuilder.Builder