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

Class SinkConfigFragment

java.lang.Object

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

io.aiven.kafka.connect.common.config.SinkConfigFragment

public final class SinkConfigFragment
extends ConfigFragment

Defines properties that are shared across all Sink implementations.

Nested Class Summary

Nested Classes

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

Field Summary

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

cfg

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
long	getMaxBytesPerFile()	A long value that represents the number of bytes per file
static SinkConfigFragment.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

Constructor Details

SinkConfigFragment

public SinkConfigFragment(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 SinkConfigFragment.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)

getMaxBytesPerFile

public long getMaxBytesPerFile()

A long value that represents the number of bytes per file

Returns:

Get the max bytes configured per file