Package io.github.flink.gcp.connector.pubsub.sink

Class PubSubSinkConfig<T>

java.lang.Object
io.github.flink.gcp.connector.pubsub.sink.PubSubSinkConfig<T>
Type Parameters:
T - type of the records written by the sink
All Implemented Interfaces:
Serializable
@Internal public final class PubSubSinkConfig<T> extends Object implements Serializable
Immutable sink configuration assembled by PubSubSinkBuilder.
See Also:

  • Method Details

    • getDestinationResolver

      public DestinationResolver<? super T> getDestinationResolver()
      Returns the per-record destination resolver.

    • getSerializer

      public PubSubSerializationSchema<? super T> getSerializer()
      Returns the record serialization schema.

    • getCreateDisposition

      public CreateDisposition getCreateDisposition()
      Returns whether the sink may create destination topics that do not exist.

    • getTopicCreateOptions

      @Nullable public TopicCreateOptions getTopicCreateOptions()
      Returns the settings applied to topics the sink creates, or null for service defaults.

    • getPublisherOptions

      public PubSubPublisherOptions getPublisherOptions()
      Returns the publisher and writer tuning options.

    • getFailedMessageHandler

      public FailureHandler<? super FailedMessage> getFailedMessageHandler()
      Returns the policy for messages that terminally fail to be published.

    • getServiceAccountKeyFile

      @Nullable public String getServiceAccountKeyFile()
      Returns the service-account key-file path, or null for ADC.

    • getEmulatorEndpoint

      @Nullable public EmulatorEndpoint getEmulatorEndpoint()
      Returns the emulator endpoint, or null for production Pub/Sub.