Index

B C F G I N P S T U V
All Classes and Interfaces|All Packages|Constant Field Values

B

build(String, String) - Static method in class io.aiven.kafka.connect.gcs.GoogleCredentialsBuilder

Builds GoogleCredentials using the provided credentials path and credentials JSON.

C

config() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConnector

configDef() - Static method in class io.aiven.kafka.connect.gcs.GcsSinkConfig

F

FILE_COMPRESSION_TYPE_CONFIG - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

FILE_MAX_RECORDS - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

FILE_NAME_PREFIX_CONFIG - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

FILE_NAME_TEMPLATE_CONFIG - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

FILE_NAME_TIMESTAMP_SOURCE - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

FILE_NAME_TIMESTAMP_TIMEZONE - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

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

FORMAT_OUTPUT_FIELDS_CONFIG - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

FORMAT_OUTPUT_FIELDS_VALUE_ENCODING_CONFIG - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

G

GCS_BUCKET_NAME_CONFIG - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GCS_CREDENTIALS_DEFAULT_CONFIG - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GCS_CREDENTIALS_JSON_CONFIG - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GCS_CREDENTIALS_PATH_CONFIG - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GCS_ENDPOINT_CONFIG - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GCS_OBJECT_CONTENT_ENCODING_CONFIG - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GCS_RETRY_BACKOFF_DELAY_MULTIPLIER_CONFIG - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GCS_RETRY_BACKOFF_DELAY_MULTIPLIER_DEFAULT - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GCS_RETRY_BACKOFF_INITIAL_DELAY_MS_CONFIG - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GCS_RETRY_BACKOFF_INITIAL_DELAY_MS_DEFAULT - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GCS_RETRY_BACKOFF_MAX_ATTEMPTS_CONFIG - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GCS_RETRY_BACKOFF_MAX_ATTEMPTS_DEFAULT - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GCS_RETRY_BACKOFF_MAX_DELAY_MS_CONFIG - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GCS_RETRY_BACKOFF_MAX_DELAY_MS_DEFAULT - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GCS_RETRY_BACKOFF_TOTAL_TIMEOUT_MS_CONFIG - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GCS_RETRY_BACKOFF_TOTAL_TIMEOUT_MS_DEFAULT - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GCS_USER_AGENT - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GcsSinkConfig - Class in io.aiven.kafka.connect.gcs

GcsSinkConfig(Map<String, String>) - Constructor for class io.aiven.kafka.connect.gcs.GcsSinkConfig

GcsSinkConfigDef - Class in io.aiven.kafka.connect.gcs

GcsSinkConfigDef() - Constructor for class io.aiven.kafka.connect.gcs.GcsSinkConfigDef

GcsSinkConnector - Class in io.aiven.kafka.connect.gcs

GcsSinkConnector() - Constructor for class io.aiven.kafka.connect.gcs.GcsSinkConnector

GcsSinkTask - Class in io.aiven.kafka.connect.gcs

GcsSinkTask() - Constructor for class io.aiven.kafka.connect.gcs.GcsSinkTask

GcsSinkTask(Map<String, String>, Storage) - Constructor for class io.aiven.kafka.connect.gcs.GcsSinkTask

getBucketName() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConfig

getCompressionType() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConfig

getConnectorName() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConfig

getCredentials() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConfig

getGcsEndpoint() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConfig

getGcsRetryBackoffDelayMultiplier() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConfig

getGcsRetryBackoffInitialDelay() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConfig

getGcsRetryBackoffMaxAttempts() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConfig

getGcsRetryBackoffMaxDelay() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConfig

getGcsRetryBackoffTotalTimeout() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConfig

getObjectContentEncoding() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConfig

getOutputFields() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConfig

getPrefix() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConfig

getUserAgent() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConfig

GoogleCredentialsBuilder - Class in io.aiven.kafka.connect.gcs

I

io.aiven.kafka.connect.gcs - package io.aiven.kafka.connect.gcs

N

NAME_CONFIG - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

P

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

S

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

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

stop() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConnector

stop() - Method in class io.aiven.kafka.connect.gcs.GcsSinkTask

T

taskClass() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConnector

taskConfigs(int) - Method in class io.aiven.kafka.connect.gcs.GcsSinkConnector

U

USER_AGENT_HEADER_VALUE - Static variable in class io.aiven.kafka.connect.gcs.GcsSinkConfig

V

validate(Map<String, String>) - Method in class io.aiven.kafka.connect.gcs.GcsSinkConfigDef

version() - Method in class io.aiven.kafka.connect.gcs.GcsSinkConnector

version() - Method in class io.aiven.kafka.connect.gcs.GcsSinkTask

B C F G I N P S T U V
All Classes and Interfaces|All Packages|Constant Field Values