Package io.confluent.kafka.serializers.schema.id

Class SchemaId

java.lang.Object

io.confluent.kafka.serializers.schema.id.SchemaId

public class SchemaId
extends Object

A SchemaId is used to identify a schema. It can be either an ID or a GUID.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	ID_SIZE
static final String	KEY_SCHEMA_ID_HEADER
static final byte	MAGIC_BYTE_V0
static final byte	MAGIC_BYTE_V1
static final String	VALUE_SCHEMA_ID_HEADER

Constructor Summary

Constructors

Constructor	Description
SchemaId(String schemaType)
SchemaId(String schemaType, Integer id, String guid)
SchemaId(String schemaType, Integer id, UUID guid)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
ByteBuffer	fromBytes(ByteBuffer buffer)
UUID	getGuid()
Integer	getId()
List<Integer>	getMessageIndexes()
byte[]	getMessageIndexesAsBytes()
String	getSchemaType()
byte[]	guidToBytes()
int	hashCode()
byte[]	idToBytes()
void	setGuid(UUID guid)
void	setId(Integer id)
void	setMessageIndexes(byte[] bytes)
void	setMessageIndexes(ByteBuffer buffer)
void	setMessageIndexes(List<Integer> messageIndexes)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

KEY_SCHEMA_ID_HEADER

public static final String KEY_SCHEMA_ID_HEADER

See Also:

• Constant Field Values

VALUE_SCHEMA_ID_HEADER

public static final String VALUE_SCHEMA_ID_HEADER

See Also:

• Constant Field Values

ID_SIZE

public static final int ID_SIZE

See Also:

• Constant Field Values

MAGIC_BYTE_V0

public static final byte MAGIC_BYTE_V0

See Also:

• Constant Field Values

MAGIC_BYTE_V1

public static final byte MAGIC_BYTE_V1

See Also:

• Constant Field Values

Constructor Details

SchemaId

public SchemaId(String schemaType)

SchemaId

public SchemaId(String schemaType,
 Integer id,
 UUID guid)

SchemaId

public SchemaId(String schemaType,
 Integer id,
 String guid)

Method Details

fromBytes

public ByteBuffer fromBytes(ByteBuffer buffer)

idToBytes

public byte[] idToBytes()
                 throws org.apache.kafka.common.errors.SerializationException

Throws:

org.apache.kafka.common.errors.SerializationException

guidToBytes

public byte[] guidToBytes()
                   throws org.apache.kafka.common.errors.SerializationException

Throws:

org.apache.kafka.common.errors.SerializationException

getSchemaType

public String getSchemaType()

getId

public Integer getId()

setId

public void setId(Integer id)

getGuid

public UUID getGuid()

setGuid

public void setGuid(UUID guid)

getMessageIndexes

public List<Integer> getMessageIndexes()

getMessageIndexesAsBytes

public byte[] getMessageIndexesAsBytes()

setMessageIndexes

public void setMessageIndexes(List<Integer> messageIndexes)

setMessageIndexes

public void setMessageIndexes(byte[] bytes)

setMessageIndexes

public void setMessageIndexes(ByteBuffer buffer)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object