Index

A E F G H I L M O S T U V 
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.
Use S3ConfigFragment.getAwsCredentialsV2() instead getAwsCredentials uses the AWS SDK 1.X which is deprecated and out of maintenance in December 2025
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
 
A E F G H I L M O S T U V 
All Classes and Interfaces|All Packages|Constant Field Values