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

Class SourceCommonConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

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

io.aiven.kafka.connect.common.config.SourceCommonConfig

public class SourceCommonConfig
extends CommonConfig

Field Summary

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

Method Summary

Modifier and Type	Method	Description
CompressionType	getCompressionType()
DistributionType	getDistributionType()
ErrorsTolerance	getErrorsTolerance()
InputFormat	getInputFormat()
int	getMaxPollRecords()
String	getNativeStartKey()
String	getSchemaRegistryUrl()
String	getSourceName()
String	getTargetTopic()
Transformer	getTransformer()
int	getTransformerMaxBufferSize()

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

Constructor Details

SourceCommonConfig

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

Method Details

getInputFormat

public InputFormat getInputFormat()

getSchemaRegistryUrl

public String getSchemaRegistryUrl()

getTargetTopic

public String getTargetTopic()

getErrorsTolerance

public ErrorsTolerance getErrorsTolerance()

getDistributionType

public DistributionType getDistributionType()

getMaxPollRecords

public int getMaxPollRecords()

getTransformer

public Transformer getTransformer()

getTransformerMaxBufferSize

public int getTransformerMaxBufferSize()

getSourceName

public String getSourceName()

getNativeStartKey

public String getNativeStartKey()

getCompressionType

public CompressionType getCompressionType()