Package io.aiven.kafka.connect.config.s3

Class S3SinkBaseConfig

java.lang.Object
org.apache.kafka.common.config.AbstractConfig
io.aiven.kafka.connect.common.config.CommonConfig
io.aiven.kafka.connect.common.config.SinkCommonConfig
io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
public class S3SinkBaseConfig extends io.aiven.kafka.connect.common.config.SinkCommonConfig

  • Field Summary

    Fields inherited from class io.aiven.kafka.connect.common.config.SinkCommonConfig

    FILE_MAX_RECORDS, fileNameFragment, outputFormatFragment

    Fields inherited from class io.aiven.kafka.connect.common.config.CommonConfig

    GROUP_COMPRESSION, GROUP_FORMAT, MAX_TASKS, TASK_ID

    Fields inherited from class org.apache.kafka.common.config.AbstractConfig

    CONFIG_PROVIDERS_CONFIG

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    S3SinkBaseConfig(org.apache.kafka.common.config.ConfigDef definition, Map<String,String> originals)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected static void
    addAwsConfigGroup(org.apache.kafka.common.config.ConfigDef configDef)
    Deprecated.
    protected static void
    addAwsStsConfigGroup(org.apache.kafka.common.config.ConfigDef configDef)
    Deprecated.
    protected static void
    addDeprecatedConfiguration(org.apache.kafka.common.config.ConfigDef configDef)
    Deprecated.
    protected static void
    addS3RetryPolicies(org.apache.kafka.common.config.ConfigDef configDef)
    Deprecated.
    software.amazon.awssdk.auth.credentials.AwsBasicCredentials
    getAwsCredentials()
     
    String
    getAwsS3BucketName()
     
    String
    getAwsS3EndPoint()
     
    int
    getAwsS3PartSize()
     
    String
    getAwsS3Prefix()
     
    software.amazon.awssdk.regions.Region
    getAwsS3Region()
     
    software.amazon.awssdk.auth.credentials.AwsCredentialsProvider
    getCustomCredentialsProvider()
     
    long
    getS3RetryBackoffDelayMs()
     
    long
    getS3RetryBackoffMaxDelayMs()
     
    int
    getS3RetryBackoffMaxRetries()
     
    String
    getServerSideEncryptionAlgorithmName()
     
    AwsStsEndpointConfig
    getStsEndpointConfig()
     
    AwsStsRole
    getStsRole()
     
    boolean
    hasAwsStsRole()
     
    boolean
    hasStsEndpointConfig()
     

    Methods inherited from class io.aiven.kafka.connect.common.config.SinkCommonConfig

    addOutputFieldsFormatConfigGroup, envelopeEnabled, getCompressionType, getFilename, getFilenameTemplate, getFilenameTimestampSource, getFilenameTimezone, getFormatType, getMaxRecordsPerFile, getOutputFieldEncodingType, getOutputFields

    Methods inherited from class io.aiven.kafka.connect.common.config.CommonConfig

    addKafkaBackoffPolicy, getKafkaRetryBackoffMs, getMaxTasks, getTaskId

    Methods inherited from class org.apache.kafka.common.config.AbstractConfig

    documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • S3SinkBaseConfig

      protected S3SinkBaseConfig(org.apache.kafka.common.config.ConfigDef definition, Map<String,String> originals)

  • Method Details

    • addDeprecatedConfiguration

      @Deprecated protected static void addDeprecatedConfiguration(org.apache.kafka.common.config.ConfigDef configDef)
      Deprecated.

    • addAwsStsConfigGroup

      @Deprecated protected static void addAwsStsConfigGroup(org.apache.kafka.common.config.ConfigDef configDef)
      Deprecated.

    • addAwsConfigGroup

      @Deprecated protected static void addAwsConfigGroup(org.apache.kafka.common.config.ConfigDef configDef)
      Deprecated.

    • addS3RetryPolicies

      @Deprecated protected static void addS3RetryPolicies(org.apache.kafka.common.config.ConfigDef configDef)
      Deprecated.

    • getStsRole

      public AwsStsRole getStsRole()

    • hasAwsStsRole

      public boolean hasAwsStsRole()

    • hasStsEndpointConfig

      public boolean hasStsEndpointConfig()

    • getStsEndpointConfig

      public AwsStsEndpointConfig getStsEndpointConfig()

    • getAwsCredentials

      public software.amazon.awssdk.auth.credentials.AwsBasicCredentials getAwsCredentials()

    • getAwsS3EndPoint

      public String getAwsS3EndPoint()

    • getAwsS3Region

      public software.amazon.awssdk.regions.Region getAwsS3Region()

    • getAwsS3BucketName

      public String getAwsS3BucketName()

    • getServerSideEncryptionAlgorithmName

      public String getServerSideEncryptionAlgorithmName()

    • getAwsS3Prefix

      public String getAwsS3Prefix()

    • getAwsS3PartSize

      public int getAwsS3PartSize()

    • getS3RetryBackoffDelayMs

      public long getS3RetryBackoffDelayMs()

    • getS3RetryBackoffMaxDelayMs

      public long getS3RetryBackoffMaxDelayMs()

    • getS3RetryBackoffMaxRetries

      public int getS3RetryBackoffMaxRetries()

    • getCustomCredentialsProvider

      public software.amazon.awssdk.auth.credentials.AwsCredentialsProvider getCustomCredentialsProvider()