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

Class AivenCommonConfig

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

@Deprecated
public class AivenCommonConfig
extends SinkCommonConfig

Deprecated.

Use SinkCommonConfig instead

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FILE_COMPRESSION_TYPE_CONFIG	Deprecated.
static final String	FILE_MAX_RECORDS	Deprecated.
static final String	FILE_NAME_TEMPLATE_CONFIG	Deprecated.
static final String	FORMAT_OUTPUT_ENVELOPE_CONFIG	Deprecated.
static final String	FORMAT_OUTPUT_FIELDS_CONFIG	Deprecated.
static final String	FORMAT_OUTPUT_FIELDS_VALUE_ENCODING_CONFIG	Deprecated.
static final String	FORMAT_OUTPUT_TYPE_CONFIG	Deprecated.

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

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AivenCommonConfig(org.apache.kafka.common.config.ConfigDef definition, Map<?,?> originals)	Deprecated.

Method Summary

Modifier and Type	Method	Description
protected static void	addFormatTypeConfig(org.apache.kafka.common.config.ConfigDef configDef, int formatGroupCounter)	Deprecated. This class and method is deprecated please use OutputFormatFragment instead to replace this functionality.

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

addCompressionTypeConfig, addOutputFieldsFormatConfigGroup, envelopeEnabled, getCompressionType, getFilename, getFilenameTemplate, getFilenameTimestampSource, getFilenameTimezone, getFormatType, getMaxRecordsPerFile, getOutputFieldEncodingType, 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

FORMAT_OUTPUT_FIELDS_CONFIG

public static final String FORMAT_OUTPUT_FIELDS_CONFIG

Deprecated.

See Also:

• Constant Field Values

FORMAT_OUTPUT_FIELDS_VALUE_ENCODING_CONFIG

public static final String FORMAT_OUTPUT_FIELDS_VALUE_ENCODING_CONFIG

Deprecated.

See Also:

• Constant Field Values

FORMAT_OUTPUT_TYPE_CONFIG

public static final String FORMAT_OUTPUT_TYPE_CONFIG

Deprecated.

See Also:

• Constant Field Values

FORMAT_OUTPUT_ENVELOPE_CONFIG

public static final String FORMAT_OUTPUT_ENVELOPE_CONFIG

Deprecated.

See Also:

• Constant Field Values

FILE_COMPRESSION_TYPE_CONFIG

public static final String FILE_COMPRESSION_TYPE_CONFIG

Deprecated.

See Also:

• Constant Field Values

FILE_MAX_RECORDS

public static final String FILE_MAX_RECORDS

Deprecated.

See Also:

• Constant Field Values

FILE_NAME_TEMPLATE_CONFIG

public static final String FILE_NAME_TEMPLATE_CONFIG

Deprecated.

See Also:

• Constant Field Values

Constructor Details

AivenCommonConfig

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

Deprecated.

Method Details

addFormatTypeConfig

protected static void addFormatTypeConfig(org.apache.kafka.common.config.ConfigDef configDef,
 int formatGroupCounter)

Deprecated.

This class and method is deprecated please use OutputFormatFragment instead to replace this functionality. alternatively switch to using the SinkCommonConfig and it will be automatically loaded in the super() method.

Parameters:

configDef - The configuration definition

formatGroupCounter - the counter to use to increment the config id