Constant Field Values

Contents

• io.aiven.*

io.aiven.*

io.aiven.commons.kafka.connector.common.config.ConnectorCommonConfigFragment

Modifier and Type	Constant Field	Value
public static final String	RELAX_SCHEMES	"io.aiven.commons.kafka.connector.common.config.RELAX_SCHEMES"

io.aiven.commons.kafka.connector.source.AbstractSourceNativeInfo<K extends Comparable<K>,N>

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

io.aiven.commons.kafka.connector.source.config.SourceConfigFragment

Modifier and Type	Constant Field	Value
public static final String	NATIVE_START_KEY	"native.start.key"

io.aiven.commons.kafka.connector.source.extractor.ExtractorInfo

Modifier and Type	Constant Field	Value
public static final int	FEATURE_INTERNAL_COMPRESSION	1
public static final int	FEATURE_NONE	0
public static final int	PRIVATE_FEATURE_SHIFT	24

io.aiven.commons.kafka.connector.source.testFixture.format.AvroTestDataFixture

Modifier and Type	Constant Field	Value
public static final String	CONNECT_EXTRA_SCHEMA_JSON	"{\n \"type\": \"record\",\n \"name\": \"TestRecord\",\n \"fields\": [\n {\"name\": \"message\", \"type\": \"string\"},\n {\"name\": \"id\", \"type\": \"int\"}\n ],\n \"connect.version\":1, \"connect.name\": \"TestRecord\"}\n"
public static final String	EVOLVED_SCHEMA_JSON	"{\n \"type\": \"record\",\n \"name\": \"TestRecord\",\n \"fields\": [\n {\"name\": \"message\", \"type\": \"string\"},\n {\"name\": \"id\", \"type\": \"int\"},\n {\"name\": \"age\", \"type\": \"int\", \"default\":0}\n ]\n}"
public static final String	MESSAGE_PREFIX	"Hello, from Avro Test Data Fixture! object: "
public static final String	SCHEMA_JSON	"{\n \"type\": \"record\",\n \"name\": \"TestRecord\",\n \"fields\": [\n {\"name\": \"message\", \"type\": \"string\"},\n {\"name\": \"id\", \"type\": \"int\"}\n ]\n}"

io.aiven.commons.kafka.connector.source.testFixture.format.CsvTestDataFixture

Modifier and Type	Constant Field	Value
public static final String	MESSAGE_PREFIX	"Hello, from CSV Test Data Fixture: "
public static final String	TEST_MESSAGE	"test message"

io.aiven.commons.kafka.connector.source.testFixture.format.JsonTestDataFixture

Modifier and Type	Constant Field	Value
public static final String	CONNECT_EXTRA_SCHEMA_JSON	"{\n \"type\": \"struct\",\n \"name\": \"TestRecord\",\n \"fields\": [\n {\"name\": \"message\", \"type\": \"string\"},\n {\"name\": \"id\", \"type\": \"int32\"}\n ],\n \"connect.version\":1, \"connect.name\": \"TestRecord\"}\n"
public static final String	EVOLVED_SCHEMA_JSON	"{\n \"type\": \"struct\",\n \"name\": \"TestRecord\",\n \"fields\": [\n {\"field\": \"message\", \"type\": \"string\"},\n {\"field\": \"id\", \"type\": \"int32\"},\n {\"field\": \"age\", \"type\": \"int32\", \"default\":0}\n ]\n}"
public static final String	MESSAGE_PREFIX	"Hello, from JSON Test Data Fixture: "
public static final String	SCHEMA_JSON	"{\n \"type\": \"struct\", \"name\": \"TestRecord\",\n \"fields\": [\n {\"field\": \"message\", \"type\": \"string\"},\n {\"field\": \"id\", \"type\": \"int32\"}\n ]\n}"
public static final String	TEST_MESSAGE	"test message"