Class ConsumerSettings.Builder (0.6.11)

public abstract static class ConsumerSettings.Builder

Inheritance

java.lang.Object > ConsumerSettings.Builder

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

Builder()

public Builder()

Methods

build()

public abstract ConsumerSettings build()

Returns

Type	Description
ConsumerSettings

setAutocommit(boolean autocommit)

public abstract ConsumerSettings.Builder setAutocommit(boolean autocommit)

The autocommit mode.

Parameter

Name	Description
autocommit	`boolean`

Returns

Type	Description
ConsumerSettings.Builder

setPerPartitionFlowControlSettings(FlowControlSettings settings)

public abstract ConsumerSettings.Builder setPerPartitionFlowControlSettings(FlowControlSettings settings)

The per-partition flow control settings.

Parameter

Name	Description
settings	`com.google.cloud.pubsublite.cloudpubsub.FlowControlSettings`

Returns

Type	Description
ConsumerSettings.Builder

setSubscriptionPath(SubscriptionPath path)

public abstract ConsumerSettings.Builder setSubscriptionPath(SubscriptionPath path)

The subscription path to use. Only the topic corresponding to this subscription can be subscribed to.

Parameter

Name	Description
path	`com.google.cloud.pubsublite.SubscriptionPath`

Returns

Type	Description
ConsumerSettings.Builder

setTopicPathOverride(TopicPath topicPath)

public abstract ConsumerSettings.Builder setTopicPathOverride(TopicPath topicPath)

An override for the TopicPath used by this consumer.

When this is set, the topic path of the subscription will not be fetched: instead, the topic used in methods will be compared with the provided TopicPath object.

This is useful if you do not have the pubsublite.subscriptions.get permission for the subscription.

Parameter

Name	Description
topicPath	`com.google.cloud.pubsublite.TopicPath`

Returns

Type	Description
ConsumerSettings.Builder