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_COMPRESSION_TYPE_CONFIG, FILE_MAX_RECORDS, FILE_NAME_TEMPLATE_CONFIG, fileNameFragment, outputFormatFragment

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

    GROUP_COMPRESSION, GROUP_FORMAT, MAX_TASKS, TASK_ID

  • 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.
    com.amazonaws.auth.BasicAWSCredentials
    getAwsCredentials()
     
    com.amazonaws.client.builder.AwsClientBuilder.EndpointConfiguration
    getAwsEndpointConfiguration()
     
    String
    getAwsS3BucketName()
     
    String
    getAwsS3EndPoint()
     
    int
    getAwsS3PartSize()
     
    String
    getAwsS3Prefix()
     
    com.amazonaws.regions.Region
    getAwsS3Region()
     
    com.amazonaws.auth.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

    addCompressionTypeConfig, 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

    equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, 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()

    • getAwsEndpointConfiguration

      public com.amazonaws.client.builder.AwsClientBuilder.EndpointConfiguration getAwsEndpointConfiguration()

    • getAwsCredentials

      public com.amazonaws.auth.BasicAWSCredentials getAwsCredentials()

    • getAwsS3EndPoint

      public String getAwsS3EndPoint()

    • getAwsS3Region

      public com.amazonaws.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 com.amazonaws.auth.AWSCredentialsProvider getCustomCredentialsProvider()