Constant Field Values

Contents

• io.aiven.*

io.aiven.*

io.aiven.kafka.connect.common.config.AivenCommonConfig

Modifier and Type	Constant Field	Value
public static final String	FILE_COMPRESSION_TYPE_CONFIG	"file.compression.type"
public static final String	FILE_MAX_RECORDS	"file.max.records"
public static final String	FILE_NAME_TEMPLATE_CONFIG	"file.name.template"
public static final String	FORMAT_OUTPUT_ENVELOPE_CONFIG	"format.output.envelope"
public static final String	FORMAT_OUTPUT_FIELDS_CONFIG	"format.output.fields"
public static final String	FORMAT_OUTPUT_FIELDS_VALUE_ENCODING_CONFIG	"format.output.fields.value.encoding"
public static final String	FORMAT_OUTPUT_TYPE_CONFIG	"format.output.type"

io.aiven.kafka.connect.common.config.CommonConfig

Modifier and Type	Constant Field	Value
protected static final String	GROUP_COMPRESSION	"File Compression"
protected static final String	GROUP_FORMAT	"Format"
public static final String	MAX_TASKS	"tasks.max"
public static final String	TASK_ID	"task.id"

io.aiven.kafka.connect.common.config.CommonConfigFragment

Modifier and Type	Constant Field	Value
protected static final String	GROUP_COMPRESSION	"File Compression"
protected static final String	GROUP_FORMAT	"Format"
public static final String	KAFKA_RETRY_BACKOFF_MS_CONFIG	"kafka.retry.backoff.ms"

io.aiven.kafka.connect.common.config.FileNameFragment

Modifier and Type	Constant Field	Value
public static final String	FILE_NAME_TEMPLATE_CONFIG	"file.name.template"
public static final String	FILE_PATH_PREFIX_TEMPLATE_CONFIG	"file.prefix.template"

io.aiven.kafka.connect.common.config.SinkCommonConfig

Modifier and Type	Constant Field	Value
public static final String	FILE_COMPRESSION_TYPE_CONFIG	"file.compression.type"
public static final String	FILE_MAX_RECORDS	"file.max.records"
public static final String	FILE_NAME_TEMPLATE_CONFIG	"file.name.template"

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

Modifier and Type	Constant Field	Value
public static final String	DISTRIBUTION_TYPE	"distribution.type"
public static final String	ERRORS_TOLERANCE	"errors.tolerance"
public static final String	EXPECTED_MAX_MESSAGE_BYTES	"expected.max.message.bytes"
public static final String	MAX_POLL_RECORDS	"max.poll.records"
public static final String	TARGET_TOPIC	"topic"

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

Modifier and Type	Constant Field	Value
public static final String	AVRO_VALUE_SERIALIZER	"value.serializer"
public static final String	INPUT_FORMAT_KEY	"input.format"
public static final String	SCHEMA_REGISTRY_URL	"schema.registry.url"
public static final String	SCHEMAS_ENABLE	"schemas.enable"
public static final String	TRANSFORMER_MAX_BUFFER_SIZE	"transformer.max.buffer.size"
public static final String	VALUE_CONVERTER_SCHEMA_REGISTRY_URL	"value.converter.schema.registry.url"

io.aiven.kafka.connect.common.source.AbstractSourceTask.Backoff

Modifier and Type	Constant Field	Value
public static final int	JITTER_SUBTRAHEND	512
public static final int	MAX_JITTER	1024

io.aiven.kafka.connect.common.source.input.Transformer

Modifier and Type	Constant Field	Value
public static final long	UNKNOWN_STREAM_LENGTH	-1L

io.aiven.kafka.connect.common.source.input.TransformerFactory

Modifier and Type	Constant Field	Value
public static final int	CACHE_SIZE	100

io.aiven.kafka.connect.common.source.input.utils.FilePatternUtils

Modifier and Type	Constant Field	Value
public static final String	NUMBER_REGEX_PATTERN	"(?:\\d+)"
public static final String	PARTITION_NAMED_GROUP_REGEX_PATTERN	"(?<partition>\\d+)"
public static final String	PARTITION_PATTERN	"{{partition}}"
public static final String	PATTERN_PARTITION_KEY	"partition"
public static final String	PATTERN_START_OFFSET_KEY	"startOffset"
public static final String	PATTERN_TOPIC_KEY	"topic"
public static final String	START_OFFSET	"Start offset"
public static final String	START_OFFSET_NAMED_GROUP_REGEX_PATTERN	"(?<startOffset>\\d+)"
public static final String	START_OFFSET_PATTERN	"{{start_offset}}"
public static final String	TIMESTAMP_PATTERN	"{{timestamp}}"
public static final String	TOPIC_NAMED_GROUP_REGEX_PATTERN	"(?<topic>[a-zA-Z0-9\\-_.]+)"
public static final String	TOPIC_PATTERN	"{{topic}}"

io.aiven.kafka.connect.common.source.task.DistributionStrategy

Modifier and Type	Constant Field	Value
public static final int	UNDEFINED	-1