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_RECORDS
static final String	FILE_NAME_TEMPLATE_CONFIG
protected final FileNameFragment	fileNameFragment	FileNameFragment to handle FileName based configuration queries.
protected final OutputFormatFragment	outputFormatFragment	OutputFormatFragment to handle Output format base configuration queries.

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

GROUP_COMPRESSION, GROUP_FORMAT, MAX_TASKS, TASK_ID

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	addCompressionTypeConfig(org.apache.kafka.common.config.ConfigDef configDef, CompressionType defaultCompressionType)
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()
final int	getMaxRecordsPerFile()
OutputFieldEncodingType	getOutputFieldEncodingType()
List<OutputField>	getOutputFields()

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

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_TEMPLATE_CONFIG

public static final String FILE_NAME_TEMPLATE_CONFIG

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.

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

addCompressionTypeConfig

protected static void addCompressionTypeConfig(org.apache.kafka.common.config.ConfigDef configDef,
 CompressionType defaultCompressionType)

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

getOutputFields

public List<OutputField> getOutputFields()