Index (s3-commons 3.4.3-SNAPSHOT API)

A B C E F G H I L M O P R S T U V
All Classes and Interfaces|All Packages|Constant Field Values

A

accessKeyId(String) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter
accessKeySecret(String) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter
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: Deprecated.
to be removed
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: Deprecated.
use SourceConfigFragment.RING_BUFFER_SIZE
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: Creates AwsCredentialProviders.
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

B

bucketName(String) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter

C

credentialsProvider(Class<? extends AwsCredentialsProvider>) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter
credentialsProvider(String) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter

E

endpoint(String) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter
endpoint(URI) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter
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
fetchPageSize(int) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter

G

getArn() - Method in class io.aiven.kafka.connect.iam.AwsStsRole
getAwsCredentials() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
getAwsCredentialsV2() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
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.S3SinkBaseConfig
getAwsS3RegionV2() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
getAwsV2Provider(S3ConfigFragment) - Method in class io.aiven.kafka.connect.iam.AwsCredentialProviderFactory: Gets an AWS V2 credential provider
getCustomCredentialsProvider() - Method in class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
getCustomCredentialsProviderV2() - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment: Gets the Aws Credentials provider.
getExternalId() - Method in class io.aiven.kafka.connect.iam.AwsStsRole
getFetchPageSize() - 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

handleDeprecatedOptions(Map<String, String>) - Static method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment: Handle moving deprecated values.
handleDeprecatedYyyyUppercase(Map<String, String>) - Static method in class io.aiven.kafka.connect.config.s3.S3CommonConfig
handleDeprecatedYyyyUppercase(Map<String, String>) - Static method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
handleDeprecations(Map<String, String>) - Static method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
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.

P

partSize(int) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter
prefix(String) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter

R

region(String) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter
region(Region) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter
retryBackoffDelay(Duration) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter
retryBackoffMaxDelay(Duration) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter
retryBackoffMaxRetries(int) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter

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
S3ConfigFragment.Setter - Class in io.aiven.kafka.connect.config.s3: A setter for the S3ConfigFragment.
S3SinkBaseConfig - Class in io.aiven.kafka.connect.config.s3
S3SinkBaseConfig(ConfigDef, Map<String, String>) - Constructor for class io.aiven.kafka.connect.config.s3.S3SinkBaseConfig
setter(Map<String, String>) - Static method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment
sseAlgorithm(String) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter
stsEndpoint(String) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter
stsRoleArn(String) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter
stsRoleExternalId(String) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter
stsRoleSessionDuration(Duration) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter
stsRoleSessionName(String) - Method in class io.aiven.kafka.connect.config.s3.S3ConfigFragment.Setter

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 B C E F G H I L M O P R S T U V
All Classes and Interfaces|All Packages|Constant Field Values