Package io.aiven.kafka.connect.azure.sink

Class AzureBlobSinkConfig

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.azure.sink.AzureBlobSinkConfig

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

Field Summary

Fields

Modifier and Type	Field	Description
static final String	AZURE_HTTP_LOG_DETAIL_LEVEL_CONFIG
static final com.azure.core.http.policy.HttpLogDetailLevel	AZURE_HTTP_LOG_DETAIL_LEVEL_DEFAULT
static final String	AZURE_RETRY_BACKOFF_INITIAL_DELAY_MS_CONFIG
static final long	AZURE_RETRY_BACKOFF_INITIAL_DELAY_MS_DEFAULT
static final String	AZURE_RETRY_BACKOFF_MAX_ATTEMPTS_CONFIG
static final int	AZURE_RETRY_BACKOFF_MAX_ATTEMPTS_DEFAULT
static final String	AZURE_RETRY_BACKOFF_MAX_DELAY_MS_CONFIG
static final long	AZURE_RETRY_BACKOFF_MAX_DELAY_MS_DEFAULT
static final String	AZURE_STORAGE_CONNECTION_STRING_CONFIG
static final String	AZURE_STORAGE_CONTAINER_NAME_CONFIG
static final String	AZURE_USER_AGENT
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	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

FILE_MAX_BYTES, fileNameFragment, outputFormatFragment, sinkConfigFragment

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

GROUP_COMPRESSION, GROUP_FORMAT, MAX_TASKS, TASK_ID

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
static org.apache.kafka.common.config.ConfigDef	configDef()
Duration	getAzureRetryBackoffInitialDelay()
int	getAzureRetryBackoffMaxAttempts()
Duration	getAzureRetryBackoffMaxDelay()
io.aiven.kafka.connect.common.config.CompressionType	getCompressionType()
String	getConnectionString()
String	getConnectorName()
String	getContainerName()
com.azure.core.http.policy.HttpLogDetailLevel	getHttpLogDetailLevel()	The detail level the Azure SDK HTTP logging policy is configured with.
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, getMaxBytesPerFile, getMaxRecordsPerFile, getOutputFieldEncodingType, isMaxBytesPerFileLimited

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

equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, 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

AZURE_STORAGE_CONNECTION_STRING_CONFIG

public static final String AZURE_STORAGE_CONNECTION_STRING_CONFIG

See Also:

• Constant Field Values

AZURE_STORAGE_CONTAINER_NAME_CONFIG

public static final String AZURE_STORAGE_CONTAINER_NAME_CONFIG

See Also:

• Constant Field Values

AZURE_USER_AGENT

public static final String AZURE_USER_AGENT

See Also:

• Constant Field Values

AZURE_HTTP_LOG_DETAIL_LEVEL_CONFIG

public static final String AZURE_HTTP_LOG_DETAIL_LEVEL_CONFIG

See Also:

• Constant Field Values

AZURE_HTTP_LOG_DETAIL_LEVEL_DEFAULT

public static final com.azure.core.http.policy.HttpLogDetailLevel AZURE_HTTP_LOG_DETAIL_LEVEL_DEFAULT

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

AZURE_RETRY_BACKOFF_INITIAL_DELAY_MS_CONFIG

public static final String AZURE_RETRY_BACKOFF_INITIAL_DELAY_MS_CONFIG

See Also:

• Constant Field Values

AZURE_RETRY_BACKOFF_MAX_DELAY_MS_CONFIG

public static final String AZURE_RETRY_BACKOFF_MAX_DELAY_MS_CONFIG

See Also:

• Constant Field Values

AZURE_RETRY_BACKOFF_MAX_ATTEMPTS_CONFIG

public static final String AZURE_RETRY_BACKOFF_MAX_ATTEMPTS_CONFIG

See Also:

• Constant Field Values

AZURE_RETRY_BACKOFF_INITIAL_DELAY_MS_DEFAULT

public static final long AZURE_RETRY_BACKOFF_INITIAL_DELAY_MS_DEFAULT

See Also:

• Constant Field Values

AZURE_RETRY_BACKOFF_MAX_DELAY_MS_DEFAULT

public static final long AZURE_RETRY_BACKOFF_MAX_DELAY_MS_DEFAULT

See Also:

• Constant Field Values

AZURE_RETRY_BACKOFF_MAX_ATTEMPTS_DEFAULT

public static final int AZURE_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

AzureBlobSinkConfig

public AzureBlobSinkConfig(Map<String,String> properties)

Method Details

configDef

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

getConnectionString

public String getConnectionString()

getContainerName

public String getContainerName()

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()

getAzureRetryBackoffMaxAttempts

public int getAzureRetryBackoffMaxAttempts()

getAzureRetryBackoffInitialDelay

public Duration getAzureRetryBackoffInitialDelay()

getAzureRetryBackoffMaxDelay

public Duration getAzureRetryBackoffMaxDelay()

getUserAgent

public String getUserAgent()

getHttpLogDetailLevel

public com.azure.core.http.policy.HttpLogDetailLevel getHttpLogDetailLevel()

The detail level the Azure SDK HTTP logging policy is configured with.

Returns:

the configured HttpLogDetailLevel, HttpLogDetailLevel.NONE by default.