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

Field Summary

Fields

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

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
Class<?>	getAvroValueSerializer()
InputFormat	getInputFormat()
String	getSchemaRegistryUrl()
int	getTransformerMaxBufferSize()
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, 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

VALUE_CONVERTER_SCHEMA_REGISTRY_URL

public static final String VALUE_CONVERTER_SCHEMA_REGISTRY_URL

See Also:

• Constant Field Values

AVRO_VALUE_SERIALIZER

public static final String AVRO_VALUE_SERIALIZER

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

update

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

getInputFormat

public InputFormat getInputFormat()

getSchemaRegistryUrl

public String getSchemaRegistryUrl()

getAvroValueSerializer

public Class<?> getAvroValueSerializer()

getTransformerMaxBufferSize

public int getTransformerMaxBufferSize()