Class PublisherBuilder.Builder (1.15.0)

public abstract static class PublisherBuilder.Builder

Inheritance

java.lang.Object > PublisherBuilder.Builder

Constructors

Builder()

public Builder()

Methods

build()

public Publisher<Offset> build()
Returns
Type Description
Publisher<Offset>
Exceptions
Type Description
ApiException

buildSequenced()

public SequencedPublisher<Offset> buildSequenced()

Builds the underlying publisher that can accept externally assigned sequence numbers for each message.

Returns
Type Description
SequencedPublisher<Offset>
Exceptions
Type Description
ApiException

setBatching(BatchingSettings batching)

public abstract PublisherBuilder.Builder setBatching(BatchingSettings batching)
Parameter
Name Description
batching BatchingSettings
Returns
Type Description
PublisherBuilder.Builder

setClientId(ByteString clientId)

public abstract PublisherBuilder.Builder setClientId(ByteString clientId)
Parameter
Name Description
clientId ByteString
Returns
Type Description
PublisherBuilder.Builder

setPartition(Partition partition)

public abstract PublisherBuilder.Builder setPartition(Partition partition)
Parameter
Name Description
partition Partition
Returns
Type Description
PublisherBuilder.Builder

setStreamFactory(StreamFactories.PublishStreamFactory streamFactory)

public abstract PublisherBuilder.Builder setStreamFactory(StreamFactories.PublishStreamFactory streamFactory)
Parameter
Name Description
streamFactory StreamFactories.PublishStreamFactory
Returns
Type Description
PublisherBuilder.Builder

setTopic(TopicPath path)

public abstract PublisherBuilder.Builder setTopic(TopicPath path)
Parameter
Name Description
path TopicPath
Returns
Type Description
PublisherBuilder.Builder