Class PublisherBuilder.Builder (1.10.0)

public abstract static class PublisherBuilder.Builder

Inheritance

java.lang.Object > PublisherBuilder.Builder

Constructors

Builder()

public Builder()

Methods

build()

public Publisher<Offset> build()
Returns
TypeDescription
Publisher<Offset>
Exceptions
TypeDescription
ApiException

buildSequenced()

public SequencedPublisher<Offset> buildSequenced()

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

Returns
TypeDescription
SequencedPublisher<Offset>
Exceptions
TypeDescription
ApiException

setBatching(BatchingSettings batching)

public abstract PublisherBuilder.Builder setBatching(BatchingSettings batching)
Parameter
NameDescription
batchingBatchingSettings
Returns

setClientId(ByteString clientId)

public abstract PublisherBuilder.Builder setClientId(ByteString clientId)
Parameter
NameDescription
clientIdByteString
Returns

setPartition(Partition partition)

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

setStreamFactory(StreamFactories.PublishStreamFactory streamFactory)

public abstract PublisherBuilder.Builder setStreamFactory(StreamFactories.PublishStreamFactory streamFactory)
Parameter
NameDescription
streamFactoryStreamFactories.PublishStreamFactory
Returns

setTopic(TopicPath path)

public abstract PublisherBuilder.Builder setTopic(TopicPath path)
Parameter
NameDescription
pathTopicPath
Returns