Index
All Classes and Interfaces|All Packages|Constant Field Values
A
- addAwsConfigGroup(ConfigDef) - Static method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
-
Deprecated.
- addAwsStsConfigGroup(ConfigDef) - Static method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
-
Deprecated.
- addDeprecatedConfiguration(ConfigDef) - Static method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
-
Deprecated.
- addS3RetryPolicies(ConfigDef) - Static method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
-
Deprecated.
- AWS_ACCESS_KEY_ID - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
- AWS_ACCESS_KEY_ID_CONFIG - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_CREDENTIAL_PROVIDER_DEFAULT - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_CREDENTIALS_PROVIDER_CONFIG - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_S3_BUCKET - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
- AWS_S3_BUCKET_NAME_CONFIG - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_S3_ENDPOINT - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
- AWS_S3_ENDPOINT_CONFIG - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_S3_FETCH_BUFFER_SIZE - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_S3_PART_SIZE - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_S3_PREFIX - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
- AWS_S3_PREFIX_CONFIG - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_S3_REGION - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
- AWS_S3_REGION_CONFIG - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_S3_RETRY_BACKOFF_DELAY_MS_CONFIG - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_S3_RETRY_BACKOFF_DELAY_MS_DEFAULT - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_S3_RETRY_BACKOFF_MAX_DELAY_MS_CONFIG - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_S3_RETRY_BACKOFF_MAX_DELAY_MS_DEFAULT - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_S3_RETRY_BACKOFF_MAX_RETRIES_CONFIG - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_S3_SSE_ALGORITHM_CONFIG - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_SECRET_ACCESS_KEY - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
- AWS_SECRET_ACCESS_KEY_CONFIG - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_STS_CONFIG_ENDPOINT - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_STS_GLOBAL_ENDPOINT - Static variable in class io.aiven.kafka.connect.iam.AwsStsEndpointConfig
- AWS_STS_ROLE_ARN - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_STS_ROLE_EXTERNAL_ID - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_STS_ROLE_SESSION_DURATION - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AWS_STS_ROLE_SESSION_NAME - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- AwsCredentialProviderFactory - Class in io.aiven.kafka.connect.iam
- AwsCredentialProviderFactory() - Constructor for class io.aiven.kafka.connect.iam.AwsCredentialProviderFactory
- AwsRegionValidator() - Constructor for class io.aiven.kafka.connect.config.s3.S3ConfigFragment.AwsRegionValidator
- AwsStsEndpointConfig - Class in io.aiven.kafka.connect.iam
- AwsStsEndpointConfig(String, String) - Constructor for class io.aiven.kafka.connect.iam.AwsStsEndpointConfig
- AwsStsRole - Class in io.aiven.kafka.connect.iam
- AwsStsRole(String, String, String, int) - Constructor for class io.aiven.kafka.connect.iam.AwsStsRole
E
- ensureValid(String, Object) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.AwsRegionValidator
F
- FETCH_PAGE_SIZE - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
G
- getArn() - Method in class io.aiven.kafka.connect.iam.AwsStsRole
- getAwsCredentials() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
- getAwsCredentials() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
- getAwsCredentialsV2() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- getAwsEndpointConfiguration() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
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.
- getAwsEndpointConfiguration() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
- getAwsS3BucketName() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- getAwsS3BucketName() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
- getAwsS3EndPoint() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- getAwsS3EndPoint() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
- getAwsS3PartSize() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- getAwsS3PartSize() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
- getAwsS3Prefix() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- getAwsS3Prefix() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
- getAwsS3Region() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.Use
S3ConfigFragment.getAwsS3RegionV2()
instead getAwsS3Region uses the AWS SDK 1.X which is deprecated and out of maintenance in December 2025 - getAwsS3Region() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
- getAwsS3RegionV2() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- getAwsV2Provider(S3ConfigFragment) - Method in class io.aiven.kafka.connect.iam.AwsCredentialProviderFactory
- getCustomCredentialsProvider() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- getCustomCredentialsProvider() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
- getCustomCredentialsProviderV2() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- getExternalId() - Method in class io.aiven.kafka.connect.iam.AwsStsRole
- getFetchPageSize() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- getProvider(S3ConfigFragment) - Method in class io.aiven.kafka.connect.iam.AwsCredentialProviderFactory
- getS3FetchBufferSize() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- getS3RetryBackoffDelayMs() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- getS3RetryBackoffDelayMs() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
- getS3RetryBackoffMaxDelayMs() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- getS3RetryBackoffMaxDelayMs() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
- getS3RetryBackoffMaxRetries() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- getS3RetryBackoffMaxRetries() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
- getServerSideEncryptionAlgorithmName() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- getServerSideEncryptionAlgorithmName() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
- getServiceEndpoint() - Method in class io.aiven.kafka.connect.iam.AwsStsEndpointConfig
- getSessionDurationSeconds() - Method in class io.aiven.kafka.connect.iam.AwsStsRole
- getSessionName() - Method in class io.aiven.kafka.connect.iam.AwsStsRole
- getSigningRegion() - Method in class io.aiven.kafka.connect.iam.AwsStsEndpointConfig
- getStsEndpointConfig() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- getStsEndpointConfig() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
- getStsRole() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- getStsRole() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
H
- handleDeprecatedYyyyUppercase(Map<String, String>) - Static method in class io.aiven.kafka.connect.config.s3.S3CommonConfig
- hasAwsStsRole() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- hasAwsStsRole() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
- hasStsEndpointConfig() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- hasStsEndpointConfig() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
I
- io.aiven.kafka.connect.config.s3 - package io.aiven.kafka.connect.config.s3
- io.aiven.kafka.connect.iam - package io.aiven.kafka.connect.iam
- isValid() - Method in class io.aiven.kafka.connect.iam.AwsStsEndpointConfig
- isValid() - Method in class io.aiven.kafka.connect.iam.AwsStsRole
L
- LOGGER - Static variable in class io.aiven.kafka.connect.config.s3.S3CommonConfig
M
- MAX_SESSION_DURATION - Static variable in class io.aiven.kafka.connect.iam.AwsStsRole
- MIN_SESSION_DURATION - Static variable in class io.aiven.kafka.connect.iam.AwsStsRole
O
- OUTPUT_COMPRESSION - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
- OUTPUT_COMPRESSION_TYPE_GZIP - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
- OUTPUT_COMPRESSION_TYPE_NONE - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
- OUTPUT_FIELD_NAME_HEADERS - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
- OUTPUT_FIELD_NAME_KEY - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
- OUTPUT_FIELD_NAME_OFFSET - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
- OUTPUT_FIELD_NAME_TIMESTAMP - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
- OUTPUT_FIELD_NAME_VALUE - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
- OUTPUT_FIELDS - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
S
- S3_RETRY_BACKOFF_MAX_RETRIES_DEFAULT - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- S3CommonConfig - Class in io.aiven.kafka.connect.config.s3
-
This common config handles a specific deprecated date format and is extensible to allow other common configuration that is not specific to a Config Fragment to be available for both sink and source configurations in S3 connectors.
- S3ConfigFragment - Class in io.aiven.kafka.connect.config.s3
-
The configuration fragment that defines the S3 specific characteristics.
- S3ConfigFragment(AbstractConfig) - Constructor for class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Constructor.
- S3ConfigFragment.AwsRegionValidator - Class in io.aiven.kafka.connect.config.s3
- S3SinkBaseConfig - Class in io.aiven.kafka.connect.config.s3
- S3SinkBaseConfig(ConfigDef, Map<String, String>) - Constructor for class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
T
- TIMESTAMP_SOURCE - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
- TIMESTAMP_TIMEZONE - Static variable in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Deprecated.
- toString() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.AwsRegionValidator
U
- update(ConfigDef) - Static method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
-
Adds the configuration options for compression to the configuration definition.
V
- validate() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- validateBucket() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
- validateCredentials() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
All Classes and Interfaces|All Packages|Constant Field Values
S3ConfigFragment.getAwsCredentialsV2()
instead getAwsCredentials uses the AWS SDK 1.X which is deprecated and out of maintenance in December 2025