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

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DISTRIBUTION_TYPE
static final String	ERRORS_TOLERANCE
static final String	EXPECTED_MAX_MESSAGE_BYTES
static final String	MAX_POLL_RECORDS
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()
ErrorsTolerance	getErrorsTolerance()
int	getExpectedMaxMessageBytes()
int	getMaxPollRecords()
String	getSourceName()
String	getTargetTopic()
static org.apache.kafka.common.config.ConfigDef	update(org.apache.kafka.common.config.ConfigDef configDef)
void	validate()	Validate that the data in the configuration matches any restrictions.

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

has

Methods inherited from class java.lang.Object

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

Field Details

MAX_POLL_RECORDS

public static final String MAX_POLL_RECORDS

See Also:

• Constant Field Values

EXPECTED_MAX_MESSAGE_BYTES

public static final String EXPECTED_MAX_MESSAGE_BYTES

See Also:

• Constant Field Values

TARGET_TOPIC

public static final String TARGET_TOPIC

See Also:

• Constant Field Values

ERRORS_TOLERANCE

public static final String ERRORS_TOLERANCE

See Also:

• Constant Field Values

DISTRIBUTION_TYPE

public static final String DISTRIBUTION_TYPE

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

update

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

validate

public void validate()

Description copied from class: ConfigFragment

Validate that the data in the configuration matches any restrictions. Default implementation does nothing.

Overrides:

validate in class ConfigFragment

getTargetTopic

public String getTargetTopic()

getSourceName

public String getSourceName()

getMaxPollRecords

public int getMaxPollRecords()

getExpectedMaxMessageBytes

public int getExpectedMaxMessageBytes()

getErrorsTolerance

public ErrorsTolerance getErrorsTolerance()

getDistributionType

public DistributionType getDistributionType()