public abstract static class PublisherSettings.Builder
Constructors
Builder()
Methods
build()
public abstract PublisherSettings build()
setAdminClient(AdminClient adminClient)
public abstract PublisherSettings.Builder setAdminClient(AdminClient adminClient)
The AdminClient to use, if provided.
setBatchingSettings(BatchingSettings batchingSettings)
public abstract PublisherSettings.Builder setBatchingSettings(BatchingSettings batchingSettings)
Batching settings for this publisher to use. Apply per-partition.
setCredentialsProvider(CredentialsProvider credentialsProvider)
public abstract PublisherSettings.Builder setCredentialsProvider(CredentialsProvider credentialsProvider)
A provider for credentials.
setEnableCompression(boolean enableCompression)
public abstract PublisherSettings.Builder setEnableCompression(boolean enableCompression)
Whether request compression is enabled. Default true.
Parameter |
---|
Name | Description |
enableCompression | boolean
|
setEnableIdempotence(boolean enableIdempotence)
public abstract PublisherSettings.Builder setEnableIdempotence(boolean enableIdempotence)
Whether idempotence is enabled, where the server will ensure that unique messages within a
single publisher session are stored only once. Default true.
Parameter |
---|
Name | Description |
enableIdempotence | boolean
|
setFramework(PubsubContext.Framework framework)
public abstract PublisherSettings.Builder setFramework(PubsubContext.Framework framework)
A Framework tag for internal metrics. Please set this if integrating with a public framework!
public abstract PublisherSettings.Builder setKeyExtractor(KeyExtractor keyExtractor)
A KeyExtractor for getting the routing key from a message.
public abstract PublisherSettings.Builder setMessageTransformer(MessageTransformer<PubsubMessage,Message> messageTransformer)
A MessageTransformer for constructing wire messages from Cloud Pub/Sub PubsubMessages.
setServiceClient(PublisherServiceClient client)
public abstract PublisherSettings.Builder setServiceClient(PublisherServiceClient client)
The PublisherServiceClient to use, if provided.
setTopicPath(TopicPath path)
public abstract PublisherSettings.Builder setTopicPath(TopicPath path)
The topic path to publish to.