Class SubscriberBuilder.Builder (1.7.1)

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

setMessageConsumer(Consumer<List<SequencedMessage>> messageConsumer)

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

setPartition(Partition partition)

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

setResetHandler(SubscriberResetHandler resetHandler)

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

setRetryStreamRaces(boolean retryStreamRaces)

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

setStreamFactory(StreamFactories.SubscribeStreamFactory streamFactory)

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

setSubscriptionPath(SubscriptionPath path)

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