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

Class S3ConfigFragment

java.lang.Object
io.aiven.kafka.connect.common.config.ConfigFragment
io.aiven.kafka.connect.config.s3.S3ConfigFragment
public final class S3ConfigFragment extends io.aiven.kafka.connect.common.config.ConfigFragment
The configuration fragment that defines the S3 specific characteristics.

  • Field Details

  • Constructor Details

    • S3ConfigFragment

      public S3ConfigFragment(org.apache.kafka.common.config.AbstractConfig cfg)
      Constructor.
      Parameters:
      cfg - the configuration to resolve requests against.

  • Method Details

    • update

      public static org.apache.kafka.common.config.ConfigDef update(org.apache.kafka.common.config.ConfigDef configDef)
      Adds the configuration options for compression to the configuration definition.
      Parameters:
      configDef - the Configuration definition.
      Returns:
      the update configuration definition

    • validate

      public void validate()
      Overrides:
      validate in class io.aiven.kafka.connect.common.config.ConfigFragment

    • validateCredentials

      public void validateCredentials()

    • validateBucket

      public void validateBucket()

    • getStsRole

      public AwsStsRole getStsRole()

    • hasAwsStsRole

      public boolean hasAwsStsRole()

    • hasStsEndpointConfig

      public boolean hasStsEndpointConfig()

    • getStsEndpointConfig

      public AwsStsEndpointConfig getStsEndpointConfig()

    • getAwsEndpointConfiguration

      @Deprecated public com.amazonaws.client.builder.AwsClientBuilder.EndpointConfiguration getAwsEndpointConfiguration()
      Deprecated.
      getAwsEndpointConfiguration uses the AWS SDK 1.X which is deprecated and out of maintenance in December 2025 After upgrading to use SDK 2.X this no longer is required.

    • getAwsCredentials

      @Deprecated public com.amazonaws.auth.BasicAWSCredentials getAwsCredentials()
      Deprecated.
      Use getAwsCredentialsV2() instead getAwsCredentials uses the AWS SDK 1.X which is deprecated and out of maintenance in December 2025

    • getAwsCredentialsV2

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

    • getAwsS3EndPoint

      public String getAwsS3EndPoint()

    • getAwsS3Region

      @Deprecated public com.amazonaws.regions.Region getAwsS3Region()
      Deprecated.
      Use getAwsS3RegionV2() instead getAwsS3Region uses the AWS SDK 1.X which is deprecated and out of maintenance in December 2025

    • getAwsS3RegionV2

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

    • 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()

    • getCustomCredentialsProviderV2

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

    • getFetchPageSize

      public int getFetchPageSize()

    • getS3FetchBufferSize

      public int getS3FetchBufferSize()