Package | Description |
---|---|
org.apache.flink.streaming.connectors.gcp.pubsub |
Modifier and Type | Method and Description |
---|---|
PubSubSource.PubSubSourceBuilder<OUT> |
PubSubSource.PubSubSourceBuilder.withCredentials(com.google.auth.Credentials credentials)
Set the credentials.
|
PubSubSource.PubSubSourceBuilder<OUT> |
PubSubSource.PubSubSourceBuilder.withMessageRateLimit(int messagePerSecondRateLimit)
Set a limit on the rate of messages per second received.
|
PubSubSource.PubSubSourceBuilder<OUT> |
PubSubSource.PubSubSourceBuilder.withPubSubSubscriberFactory(int maxMessagesPerPull,
java.time.Duration perRequestTimeout,
int retries)
There is a default PubSubSubscriber factory that uses gRPC to pull in PubSub messages.
|
PubSubSource.PubSubSourceBuilder<OUT> |
PubSubSource.PubSubSourceBuilder.withPubSubSubscriberFactory(PubSubSubscriberFactory pubSubSubscriberFactory)
Set a PubSubSubscriberFactory This allows for custom Subscriber options to be set.
|
PubSubSource.PubSubSourceBuilder<OUT> |
PubSubSource.PubSubSourceBuilder.withSubscriptionName(String subscriptionName) |
PubSubSource.PubSubSourceBuilder<OUT> |
PubSubSource.SubscriptionNameBuilder.withSubscriptionName(String subscriptionName)
Set the subscription name of the subscription to pull messages from.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.