Package io.github.flink.gcp.connector.pubsub.sink
package io.github.flink.gcp.connector.pubsub.sink
-
ClassDescriptionWhether the sink may create destination topics that do not exist.CrossVersionSink<InputT>The cross-version seam every sink in this module implements instead of
Sinkdirectly.Resolves the destination topic for each record, enabling one sink instance to publish to many topics (dynamic destinations).A single message that terminally failed to be published to Pub/Sub, as passed to aFailureHandler<FailedMessage>.ADestinationResolverreturning one fixed destination for every record.Tuning options for the sink's Pub/Sub publishers and its writer: SDK batching and publish-retry settings, message ordering, the writer's in-flight caps, the backoff budget of the topic auto-creation recovery, and the writer's shutdown budget.Builder forPubSubPublisherOptions.At-least-once sink publishing throughgoogle-cloud-pubsubPublisherinstances with dynamic per-record topic destinations.Entry point for building a Pub/Sub sink.Builder for Pub/Sub sinks, obtained fromPubSubSink.builder().Immutable sink configuration assembled byPubSubSinkBuilder.Settings the sink applies when it creates a topic that does not exist.Builder forTopicCreateOptions.A fully-qualified Pub/Sub topic reference: project and topic.