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

Class TransformerFragment

java.lang.Object

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

io.aiven.kafka.connect.common.config.TransformerFragment

public final class TransformerFragment
extends ConfigFragment

Fragment to manage transformer configuration.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TransformerFragment.InputFormatValidator
static final class	TransformerFragment.Setter	The setter for the TransformerFragment

Field Summary

Fields

Modifier and Type	Field	Description
static final String	INPUT_FORMAT_KEY
static final String	SCHEMA_REGISTRY_URL
static final String	SCHEMAS_ENABLE
static final String	TRANSFORMER_MAX_BUFFER_SIZE

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

cfg

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
InputFormat	getInputFormat()	Gets the input format for the transformer.
String	getSchemaRegistryUrl()	Get the schema registry URL.
int	getTransformerMaxBufferSize()	Gets the maximum buffer size for the BYTE input.
static TransformerFragment.Setter	setter(Map<String,String> data)	Creates a Setter for this fragment.
static org.apache.kafka.common.config.ConfigDef	update(org.apache.kafka.common.config.ConfigDef configDef)	Update the configuration definition with the properties for this fragment.

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

SCHEMA_REGISTRY_URL

public static final String SCHEMA_REGISTRY_URL

See Also:

• Constant Field Values

INPUT_FORMAT_KEY

public static final String INPUT_FORMAT_KEY

See Also:

• Constant Field Values

SCHEMAS_ENABLE

public static final String SCHEMAS_ENABLE

See Also:

• Constant Field Values

TRANSFORMER_MAX_BUFFER_SIZE

public static final String TRANSFORMER_MAX_BUFFER_SIZE

See Also:

• Constant Field Values

Constructor Details

TransformerFragment

public TransformerFragment(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 TransformerFragment.Setter setter(Map<String,String> data)

Creates 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)

Update the configuration definition with the properties for this fragment.

Parameters:

configDef - the configuration definition to update.

Returns:

the updated configuration definition.

getInputFormat

public InputFormat getInputFormat()

Gets the input format for the transformer.

Returns:

the Input format for the

getSchemaRegistryUrl

public String getSchemaRegistryUrl()

Get the schema registry URL.

Returns:

the schema registry URL

getTransformerMaxBufferSize

public int getTransformerMaxBufferSize()

Gets the maximum buffer size for the BYTE input.

Returns:

the maximum buffer size fo the BYTE input.