Index

A C D E F G I K L O P S T U V W
All Classes and Interfaces|All Packages|Constant Field Values

A

AivenKafkaConnectS3SinkConnector - Class in io.aiven.kafka.connect.s3

AivenKafkaConnectS3SinkConnector() - Constructor for class io.aiven.kafka.connect.s3.AivenKafkaConnectS3SinkConnector

AWS_S3_RETRY_BACKOFF_DELAY_MS_DEFAULT - Static variable in class io.aiven.kafka.connect.s3.config.S3SinkConfig

AWS_S3_RETRY_BACKOFF_MAX_DELAY_MS_DEFAULT - Static variable in class io.aiven.kafka.connect.s3.config.S3SinkConfig

AwsRegionValidator() - Constructor for class io.aiven.kafka.connect.s3.config.S3SinkConfig.AwsRegionValidator

Deprecated.

C

close() - Method in class io.aiven.kafka.connect.s3.S3OutputStream

config() - Method in class io.aiven.kafka.connect.s3.AivenKafkaConnectS3SinkConnector

configDef() - Static method in class io.aiven.kafka.connect.s3.config.S3SinkConfig

D

DEFAULT_PART_SIZE - Static variable in class io.aiven.kafka.connect.s3.S3OutputStream

E

ensureValid(String, Object) - Method in class io.aiven.kafka.connect.s3.config.S3SinkConfig.AwsRegionValidator

Deprecated.

F

flush(Map<TopicPartition, OffsetAndMetadata>) - Method in class io.aiven.kafka.connect.s3.S3SinkTask

G

getCompressionType() - Method in class io.aiven.kafka.connect.s3.config.S3SinkConfig

getOutputFields() - Method in class io.aiven.kafka.connect.s3.config.S3SinkConfig

Gets the list of output fields.

getOutputFields(String) - Method in class io.aiven.kafka.connect.s3.config.S3SinkConfig

Deprecated.

getPrefixTemplate() - Method in class io.aiven.kafka.connect.s3.config.S3SinkConfig

getTimestampSource() - Method in class io.aiven.kafka.connect.s3.config.S3SinkConfig

getTimezone() - Method in class io.aiven.kafka.connect.s3.config.S3SinkConfig

I

io.aiven.kafka.connect.s3 - package io.aiven.kafka.connect.s3

io.aiven.kafka.connect.s3.config - package io.aiven.kafka.connect.s3.config

K

KAFKA_OFFSET - Static variable in class io.aiven.kafka.connect.s3.OldFullKeyFormatters

L

LOGGER - Static variable in class io.aiven.kafka.connect.s3.config.S3SinkConfig

O

OldFullKeyFormatters - Class in io.aiven.kafka.connect.s3

P

put(Collection<SinkRecord>) - Method in class io.aiven.kafka.connect.s3.S3SinkTask

S

S3_RETRY_BACKOFF_MAX_RETRIES_DEFAULT - Static variable in class io.aiven.kafka.connect.s3.config.S3SinkConfig

S3OutputStream - Class in io.aiven.kafka.connect.s3

S3OutputStream(String, String, int, AmazonS3) - Constructor for class io.aiven.kafka.connect.s3.S3OutputStream

S3OutputStream(String, String, int, AmazonS3, String) - Constructor for class io.aiven.kafka.connect.s3.S3OutputStream

S3SinkConfig - Class in io.aiven.kafka.connect.s3.config

S3SinkConfig(Map<String, String>) - Constructor for class io.aiven.kafka.connect.s3.config.S3SinkConfig

S3SinkConfig.AwsRegionValidator - Class in io.aiven.kafka.connect.s3.config

Deprecated.

S3SinkConfigDef - Class in io.aiven.kafka.connect.s3.config

S3SinkConfigDef() - Constructor for class io.aiven.kafka.connect.s3.config.S3SinkConfigDef

S3SinkTask - Class in io.aiven.kafka.connect.s3

S3SinkTask() - Constructor for class io.aiven.kafka.connect.s3.S3SinkTask

start(Map<String, String>) - Method in class io.aiven.kafka.connect.s3.AivenKafkaConnectS3SinkConnector

start(Map<String, String>) - Method in class io.aiven.kafka.connect.s3.S3SinkTask

stop() - Method in class io.aiven.kafka.connect.s3.AivenKafkaConnectS3SinkConnector

stop() - Method in class io.aiven.kafka.connect.s3.S3SinkTask

T

taskClass() - Method in class io.aiven.kafka.connect.s3.AivenKafkaConnectS3SinkConnector

taskConfigs(int) - Method in class io.aiven.kafka.connect.s3.AivenKafkaConnectS3SinkConnector

U

usesFileNameTemplate() - Method in class io.aiven.kafka.connect.s3.config.S3SinkConfig

V

validate(Map<String, String>) - Method in class io.aiven.kafka.connect.s3.config.S3SinkConfigDef

version() - Method in class io.aiven.kafka.connect.s3.AivenKafkaConnectS3SinkConnector

version() - Method in class io.aiven.kafka.connect.s3.S3SinkTask

W

write(byte[], int, int) - Method in class io.aiven.kafka.connect.s3.S3OutputStream

write(int) - Method in class io.aiven.kafka.connect.s3.S3OutputStream

A C D E F G I K L O P S T U V W
All Classes and Interfaces|All Packages|Constant Field Values