Package io.confluent.connect.schema.backup.api

Class BackupWrapper

java.lang.Object

io.confluent.connect.schema.backup.api.BackupWrapper

public final class BackupWrapper
extends Object

Backup Wrapper struct for carrying schema metadata between converters and the envelope layer. Only SR-aware converters (AvroConverter, ProtobufConverter, JsonSchemaConverter) emit this wrapper when schema.backup.enabled=true. Non-SR converters such as ByteArrayConverter, JsonConverter, and StringConverter bypass this path because they carry no Schema Registry metadata to preserve.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BackupWrapper.WrapperFields	Groups metadata fields for buildWrapper(org.apache.kafka.connect.data.Schema, java.lang.Object, io.confluent.connect.schema.backup.api.BackupWrapper.WrapperFields) to reduce parameter count.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FIELD_DATA
static final String	FIELD_DIRECT_REFS
static final String	FIELD_RAW_SCHEMA
static final String	FIELD_REFERENCE_TREE
static final String	FIELD_SCHEMA_GUID
static final String	FIELD_SCHEMA_ID
static final String	FIELD_SCHEMA_SUBJECT
static final String	FIELD_SCHEMA_TYPE
static final String	FIELD_SCHEMA_VERSION
static final String	NAME

Method Summary

Modifier and Type	Method	Description
static org.apache.kafka.connect.data.Schema	buildSchema(org.apache.kafka.connect.data.Schema dataSchema)
static org.apache.kafka.connect.data.Struct	buildWrapper(org.apache.kafka.connect.data.Schema wrapperSchema, Object data, BackupWrapper.WrapperFields fields)
static boolean	isWrapper(org.apache.kafka.connect.data.Schema schema)
static void	requireFields(org.apache.kafka.connect.data.Schema wrapperSchema, String... fields)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

NAME

public static final String NAME

See Also:

• Constant Field Values

FIELD_DATA

public static final String FIELD_DATA

See Also:

• Constant Field Values

FIELD_SCHEMA_ID

public static final String FIELD_SCHEMA_ID

See Also:

• Constant Field Values

FIELD_SCHEMA_VERSION

public static final String FIELD_SCHEMA_VERSION

See Also:

• Constant Field Values

FIELD_SCHEMA_TYPE

public static final String FIELD_SCHEMA_TYPE

See Also:

• Constant Field Values

FIELD_SCHEMA_SUBJECT

public static final String FIELD_SCHEMA_SUBJECT

See Also:

• Constant Field Values

FIELD_RAW_SCHEMA

public static final String FIELD_RAW_SCHEMA

See Also:

• Constant Field Values

FIELD_REFERENCE_TREE

public static final String FIELD_REFERENCE_TREE

See Also:

• Constant Field Values

FIELD_DIRECT_REFS

public static final String FIELD_DIRECT_REFS

See Also:

• Constant Field Values

FIELD_SCHEMA_GUID

public static final String FIELD_SCHEMA_GUID

See Also:

• Constant Field Values

Method Details

buildSchema

public static org.apache.kafka.connect.data.Schema buildSchema(org.apache.kafka.connect.data.Schema dataSchema)

buildWrapper

public static org.apache.kafka.connect.data.Struct buildWrapper(org.apache.kafka.connect.data.Schema wrapperSchema,
 Object data,
 BackupWrapper.WrapperFields fields)

isWrapper

public static boolean isWrapper(org.apache.kafka.connect.data.Schema schema)

requireFields

public static void requireFields(org.apache.kafka.connect.data.Schema wrapperSchema,
 String... fields)