Package io.aiven.kafka.connect.gcs

Class GcsSinkConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.aiven.kafka.connect.common.config.CommonConfig

io.aiven.kafka.connect.common.config.SinkCommonConfig

io.aiven.kafka.connect.common.config.AivenCommonConfig

io.aiven.kafka.connect.gcs.GcsSinkConfig

public final class GcsSinkConfig
extends io.aiven.kafka.connect.common.config.AivenCommonConfig

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FILE_COMPRESSION_TYPE_CONFIG
static final String	FILE_MAX_RECORDS
static final String	FILE_NAME_PREFIX_CONFIG
static final String	FILE_NAME_TEMPLATE_CONFIG
static final String	FILE_NAME_TIMESTAMP_SOURCE
static final String	FILE_NAME_TIMESTAMP_TIMEZONE
static final String	FORMAT_OUTPUT_FIELDS_CONFIG
static final String	FORMAT_OUTPUT_FIELDS_VALUE_ENCODING_CONFIG
static final String	GCS_BUCKET_NAME_CONFIG
static final String	GCS_CREDENTIALS_DEFAULT_CONFIG
static final String	GCS_CREDENTIALS_JSON_CONFIG
static final String	GCS_CREDENTIALS_PATH_CONFIG
static final String	GCS_ENDPOINT_CONFIG
static final String	GCS_OBJECT_CONTENT_ENCODING_CONFIG
static final String	GCS_RETRY_BACKOFF_DELAY_MULTIPLIER_CONFIG
static final double	GCS_RETRY_BACKOFF_DELAY_MULTIPLIER_DEFAULT
static final String	GCS_RETRY_BACKOFF_INITIAL_DELAY_MS_CONFIG
static final long	GCS_RETRY_BACKOFF_INITIAL_DELAY_MS_DEFAULT
static final String	GCS_RETRY_BACKOFF_MAX_ATTEMPTS_CONFIG
static final int	GCS_RETRY_BACKOFF_MAX_ATTEMPTS_DEFAULT
static final String	GCS_RETRY_BACKOFF_MAX_DELAY_MS_CONFIG
static final long	GCS_RETRY_BACKOFF_MAX_DELAY_MS_DEFAULT
static final String	GCS_RETRY_BACKOFF_TOTAL_TIMEOUT_MS_CONFIG
static final long	GCS_RETRY_BACKOFF_TOTAL_TIMEOUT_MS_DEFAULT
static final String	GCS_USER_AGENT
static final String	NAME_CONFIG
static final String	USER_AGENT_HEADER_VALUE

Fields inherited from class io.aiven.kafka.connect.common.config.AivenCommonConfig

FORMAT_OUTPUT_ENVELOPE_CONFIG, FORMAT_OUTPUT_TYPE_CONFIG

Fields inherited from class io.aiven.kafka.connect.common.config.SinkCommonConfig

fileNameFragment, outputFormatFragment

Fields inherited from class io.aiven.kafka.connect.common.config.CommonConfig

GROUP_COMPRESSION, GROUP_FORMAT, MAX_TASKS, TASK_ID

Fields inherited from class org.apache.kafka.common.config.AbstractConfig

CONFIG_PROVIDERS_CONFIG

Constructor Summary

Constructors

Constructor	Description
GcsSinkConfig(Map<String,String> properties)

Method Summary

Modifier and Type	Method	Description
static org.apache.kafka.common.config.ConfigDef	configDef()
String	getBucketName()
io.aiven.kafka.connect.common.config.CompressionType	getCompressionType()
String	getConnectorName()
com.google.auth.oauth2.OAuth2Credentials	getCredentials()
String	getGcsEndpoint()
double	getGcsRetryBackoffDelayMultiplier()
Duration	getGcsRetryBackoffInitialDelay()
int	getGcsRetryBackoffMaxAttempts()
Duration	getGcsRetryBackoffMaxDelay()
Duration	getGcsRetryBackoffTotalTimeout()
String	getObjectContentEncoding()
List<io.aiven.kafka.connect.common.config.OutputField>	getOutputFields()
String	getPrefix()
String	getUserAgent()

Methods inherited from class io.aiven.kafka.connect.common.config.AivenCommonConfig

addFormatTypeConfig

Methods inherited from class io.aiven.kafka.connect.common.config.SinkCommonConfig

addOutputFieldsFormatConfigGroup, envelopeEnabled, getFilename, getFilenameTemplate, getFilenameTimestampSource, getFilenameTimezone, getFormatType, getMaxRecordsPerFile, getOutputFieldEncodingType

Methods inherited from class io.aiven.kafka.connect.common.config.CommonConfig

addKafkaBackoffPolicy, getKafkaRetryBackoffMs, getMaxTasks, getTaskId

Methods inherited from class org.apache.kafka.common.config.AbstractConfig

documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Details

USER_AGENT_HEADER_VALUE

public static final String USER_AGENT_HEADER_VALUE

GCS_CREDENTIALS_PATH_CONFIG

public static final String GCS_CREDENTIALS_PATH_CONFIG

See Also:

• Constant Field Values

GCS_ENDPOINT_CONFIG

public static final String GCS_ENDPOINT_CONFIG

See Also:

• Constant Field Values

GCS_CREDENTIALS_JSON_CONFIG

public static final String GCS_CREDENTIALS_JSON_CONFIG

See Also:

• Constant Field Values

GCS_CREDENTIALS_DEFAULT_CONFIG

public static final String GCS_CREDENTIALS_DEFAULT_CONFIG

See Also:

• Constant Field Values

GCS_BUCKET_NAME_CONFIG

public static final String GCS_BUCKET_NAME_CONFIG

See Also:

• Constant Field Values

GCS_OBJECT_CONTENT_ENCODING_CONFIG

public static final String GCS_OBJECT_CONTENT_ENCODING_CONFIG

See Also:

• Constant Field Values

GCS_USER_AGENT

public static final String GCS_USER_AGENT

See Also:

• Constant Field Values

FILE_NAME_PREFIX_CONFIG

public static final String FILE_NAME_PREFIX_CONFIG

See Also:

• Constant Field Values

FILE_NAME_TEMPLATE_CONFIG

public static final String FILE_NAME_TEMPLATE_CONFIG

See Also:

• Constant Field Values

FILE_COMPRESSION_TYPE_CONFIG

public static final String FILE_COMPRESSION_TYPE_CONFIG

See Also:

• Constant Field Values

FILE_MAX_RECORDS

public static final String FILE_MAX_RECORDS

See Also:

• Constant Field Values

FILE_NAME_TIMESTAMP_TIMEZONE

public static final String FILE_NAME_TIMESTAMP_TIMEZONE

See Also:

• Constant Field Values

FILE_NAME_TIMESTAMP_SOURCE

public static final String FILE_NAME_TIMESTAMP_SOURCE

See Also:

• Constant Field Values

FORMAT_OUTPUT_FIELDS_CONFIG

public static final String FORMAT_OUTPUT_FIELDS_CONFIG

See Also:

• Constant Field Values

FORMAT_OUTPUT_FIELDS_VALUE_ENCODING_CONFIG

public static final String FORMAT_OUTPUT_FIELDS_VALUE_ENCODING_CONFIG

See Also:

• Constant Field Values

GCS_RETRY_BACKOFF_INITIAL_DELAY_MS_CONFIG

public static final String GCS_RETRY_BACKOFF_INITIAL_DELAY_MS_CONFIG

See Also:

• Constant Field Values

GCS_RETRY_BACKOFF_MAX_DELAY_MS_CONFIG

public static final String GCS_RETRY_BACKOFF_MAX_DELAY_MS_CONFIG

See Also:

• Constant Field Values

GCS_RETRY_BACKOFF_DELAY_MULTIPLIER_CONFIG

public static final String GCS_RETRY_BACKOFF_DELAY_MULTIPLIER_CONFIG

See Also:

• Constant Field Values

GCS_RETRY_BACKOFF_TOTAL_TIMEOUT_MS_CONFIG

public static final String GCS_RETRY_BACKOFF_TOTAL_TIMEOUT_MS_CONFIG

See Also:

• Constant Field Values

GCS_RETRY_BACKOFF_MAX_ATTEMPTS_CONFIG

public static final String GCS_RETRY_BACKOFF_MAX_ATTEMPTS_CONFIG

See Also:

• Constant Field Values

GCS_RETRY_BACKOFF_INITIAL_DELAY_MS_DEFAULT

public static final long GCS_RETRY_BACKOFF_INITIAL_DELAY_MS_DEFAULT

See Also:

• Constant Field Values

GCS_RETRY_BACKOFF_MAX_DELAY_MS_DEFAULT

public static final long GCS_RETRY_BACKOFF_MAX_DELAY_MS_DEFAULT

See Also:

• Constant Field Values

GCS_RETRY_BACKOFF_DELAY_MULTIPLIER_DEFAULT

public static final double GCS_RETRY_BACKOFF_DELAY_MULTIPLIER_DEFAULT

See Also:

• Constant Field Values

GCS_RETRY_BACKOFF_TOTAL_TIMEOUT_MS_DEFAULT

public static final long GCS_RETRY_BACKOFF_TOTAL_TIMEOUT_MS_DEFAULT

See Also:

• Constant Field Values

GCS_RETRY_BACKOFF_MAX_ATTEMPTS_DEFAULT

public static final int GCS_RETRY_BACKOFF_MAX_ATTEMPTS_DEFAULT

See Also:

• Constant Field Values

NAME_CONFIG

public static final String NAME_CONFIG

See Also:

• Constant Field Values

Constructor Details

GcsSinkConfig

public GcsSinkConfig(Map<String,String> properties)

Method Details

configDef

public static org.apache.kafka.common.config.ConfigDef configDef()

getCredentials

public com.google.auth.oauth2.OAuth2Credentials getCredentials()

getBucketName

public String getBucketName()

getObjectContentEncoding

public String getObjectContentEncoding()

getCompressionType

public io.aiven.kafka.connect.common.config.CompressionType getCompressionType()

Overrides:

getCompressionType in class io.aiven.kafka.connect.common.config.SinkCommonConfig

getOutputFields

public List<io.aiven.kafka.connect.common.config.OutputField> getOutputFields()

Overrides:

getOutputFields in class io.aiven.kafka.connect.common.config.SinkCommonConfig

getPrefix

public String getPrefix()

getConnectorName

public String getConnectorName()

getGcsRetryBackoffMaxAttempts

public int getGcsRetryBackoffMaxAttempts()

getGcsRetryBackoffDelayMultiplier

public double getGcsRetryBackoffDelayMultiplier()

getGcsRetryBackoffTotalTimeout

public Duration getGcsRetryBackoffTotalTimeout()

getGcsRetryBackoffInitialDelay

public Duration getGcsRetryBackoffInitialDelay()

getGcsRetryBackoffMaxDelay

public Duration getGcsRetryBackoffMaxDelay()

getGcsEndpoint

public String getGcsEndpoint()

getUserAgent

public String getUserAgent()