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

Class SourceConfigFragment

java.lang.Object

io.aiven.kafka.connect.common.config.ConfigFragment

io.aiven.kafka.connect.common.config.SourceConfigFragment

public final class SourceConfigFragment
extends ConfigFragment

Defines properties that are shared across all Source implementations.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SourceConfigFragment.Setter	The SourceConfigFragment setter.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	NATIVE_START_KEY
static final String	RING_BUFFER_SIZE
static final String	TARGET_TOPIC

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

cfg

Constructor Summary

Constructors

Constructor	Description
SourceConfigFragment(org.apache.kafka.common.config.AbstractConfig cfg)	Construct the ConfigFragment.

Method Summary

Modifier and Type	Method	Description
DistributionType	getDistributionType()	Gets the distribution type
org.apache.kafka.connect.runtime.errors.ToleranceType	getErrorsTolerance()	Gets the errors tolerance.
int	getMaxPollRecords()	Gets the maximum number of records to poll at one time.
String	getNativeStartKey()	Gets the nativeStartKey.
int	getRingBufferSize()	Gets the ring buffer size.
String	getTargetTopic()	Gets the target topic.
static SourceConfigFragment.Setter	setter(Map<String,String> data)	Gets a setter for this fragment.
static org.apache.kafka.common.config.ConfigDef	update(org.apache.kafka.common.config.ConfigDef configDef)

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

has, logDeprecated, logDeprecated, logDeprecated, validate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

TARGET_TOPIC

public static final String TARGET_TOPIC

See Also:

• Constant Field Values

RING_BUFFER_SIZE

public static final String RING_BUFFER_SIZE

See Also:

• Constant Field Values

NATIVE_START_KEY

public static final String NATIVE_START_KEY

See Also:

• Constant Field Values

Constructor Details

SourceConfigFragment

public SourceConfigFragment(org.apache.kafka.common.config.AbstractConfig cfg)

Construct the ConfigFragment.

Parameters:

cfg - the configuration that this fragment is associated with.

Method Details

setter

public static SourceConfigFragment.Setter setter(Map<String,String> data)

Gets a setter for this fragment.

Parameters:

data - the data map to modify.

Returns:

the Setter.

update

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

getTargetTopic

public String getTargetTopic()

Gets the target topic.

Returns:

the target topic.

getMaxPollRecords

public int getMaxPollRecords()

Gets the maximum number of records to poll at one time.

Returns:

The maximum number of records to poll at one time.

getErrorsTolerance

public org.apache.kafka.connect.runtime.errors.ToleranceType getErrorsTolerance()

Gets the errors tolerance.

Returns:

the errors tolerance.

getDistributionType

public DistributionType getDistributionType()

Gets the distribution type

Returns:

the distribution type.

getRingBufferSize

public int getRingBufferSize()

Gets the ring buffer size.

Returns:

the ring buffer size.

getNativeStartKey

public String getNativeStartKey()

Gets the nativeStartKey.

Returns:

the key to start consuming records from.