Package io.aiven.kafka.connect.common.config

Class SinkCommonConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

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

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

Direct Known Subclasses:

AivenCommonConfig

public class SinkCommonConfig
extends CommonConfig

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FILE_COMPRESSION_TYPE_CONFIG
static final String	FILE_MAX_BYTES
static final String	FILE_MAX_RECORDS
static final String	FILE_NAME_TEMPLATE_CONFIG
protected final FileNameFragment	fileNameFragment	FileNameFragment to handle FileName based configuration queries.
static final String	FORMAT_OUTPUT_ENVELOPE_CONFIG
static final String	FORMAT_OUTPUT_FIELDS_CONFIG
static final String	FORMAT_OUTPUT_FIELDS_VALUE_ENCODING_CONFIG
static final String	FORMAT_OUTPUT_TYPE_CONFIG
protected final OutputFormatFragment	outputFormatFragment	OutputFormatFragment to handle Output format base configuration queries.
protected final SinkConfigFragment	sinkConfigFragment

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
SinkCommonConfig(org.apache.kafka.common.config.ConfigDef definition, Map<?,?> originals)

Method Summary

Modifier and Type	Method	Description
protected static void	addOutputFieldsFormatConfigGroup(org.apache.kafka.common.config.ConfigDef configDef, OutputFieldType defaultFieldType)
Boolean	envelopeEnabled()
CompressionType	getCompressionType()
final String	getFilename()
final Template	getFilenameTemplate()
final TimestampSource	getFilenameTimestampSource()
final ZoneId	getFilenameTimezone()
FormatType	getFormatType()
long	getMaxBytesPerFile()
final int	getMaxRecordsPerFile()
OutputFieldEncodingType	getOutputFieldEncodingType()
List<OutputField>	getOutputFields()
boolean	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

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

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

FORMAT_OUTPUT_TYPE_CONFIG

public static final String FORMAT_OUTPUT_TYPE_CONFIG

See Also:

• Constant Field Values

FORMAT_OUTPUT_ENVELOPE_CONFIG

public static final String FORMAT_OUTPUT_ENVELOPE_CONFIG

See Also:

• Constant Field Values

FILE_COMPRESSION_TYPE_CONFIG

public static final String FILE_COMPRESSION_TYPE_CONFIG

See Also:

• Constant Field Values

FILE_NAME_TEMPLATE_CONFIG

public static final String FILE_NAME_TEMPLATE_CONFIG

See Also:

• Constant Field Values

FILE_MAX_RECORDS

public static final String FILE_MAX_RECORDS

See Also:

• Constant Field Values

FILE_MAX_BYTES

public static final String FILE_MAX_BYTES

See Also:

• Constant Field Values

fileNameFragment

protected final FileNameFragment fileNameFragment

FileNameFragment to handle FileName based configuration queries.

outputFormatFragment

protected final OutputFormatFragment outputFormatFragment

OutputFormatFragment to handle Output format base configuration queries.

sinkConfigFragment

protected final SinkConfigFragment sinkConfigFragment

Constructor Details

SinkCommonConfig

public SinkCommonConfig(org.apache.kafka.common.config.ConfigDef definition,
 Map<?,?> originals)

Method Details

addOutputFieldsFormatConfigGroup

protected static void addOutputFieldsFormatConfigGroup(org.apache.kafka.common.config.ConfigDef configDef,
 OutputFieldType defaultFieldType)

getFormatType

public FormatType getFormatType()

getCompressionType

public CompressionType getCompressionType()

envelopeEnabled

public Boolean envelopeEnabled()

getOutputFieldEncodingType

public OutputFieldEncodingType getOutputFieldEncodingType()

getFilenameTemplate

public final Template getFilenameTemplate()

getFilename

public final String getFilename()

getFilenameTimezone

public final ZoneId getFilenameTimezone()

getFilenameTimestampSource

public final TimestampSource getFilenameTimestampSource()

getMaxRecordsPerFile

public final int getMaxRecordsPerFile()

getMaxBytesPerFile

public long getMaxBytesPerFile()

isMaxBytesPerFileLimited

public boolean isMaxBytesPerFileLimited()

getOutputFields

public List<OutputField> getOutputFields()