org.nuxeo.lib.stream.codec

Class AvroConfluentCodec<T>

java.lang.Object

org.nuxeo.lib.stream.codec.AvroConfluentCodec<T>

All Implemented Interfaces:

Codec<T>

public class AvroConfluentCodec<T>
extends Object
implements Codec<T>

Use the Confluent Avro encoding which differs from Avro message, the schema store is a REST Confluent Schema Registry.

Since:

10.3

Field Summary

Fields

Modifier and Type	Field and Description
protected io.confluent.kafka.schemaregistry.client.SchemaRegistryClient	client
protected static int	DEFAULT_IDENTITY_MAP_CAPACITY
protected org.apache.avro.message.RawMessageEncoder<T>	encoder
protected static int	ID_SIZE
protected static byte	MAGIC_BYTE
protected Class<T>	messageClass
static String	NAME
protected org.apache.avro.Schema	schema
protected int	schemaId
protected String	schemaName
protected io.confluent.kafka.serializers.KafkaAvroSerializer	serializer

Constructor Summary

Constructors

Constructor and Description
AvroConfluentCodec(Class<T> messageClass, String schemaRegistryUrls) Create an AvroConfluent codec

Method Summary

Modifier and Type	Method and Description
T	decode(byte[] data) Decodes the byte array returns an object.
byte[]	encode(T object) Encodes the object returns a byte array representation.
String	getName() Returns the codec name

Methods inherited from class java.lang.Object

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

Field Detail

NAME

public static final String NAME

See Also:

Constant Field Values

MAGIC_BYTE

protected static final byte MAGIC_BYTE

See Also:

Constant Field Values

ID_SIZE

protected static final int ID_SIZE

See Also:

Constant Field Values

DEFAULT_IDENTITY_MAP_CAPACITY

protected static final int DEFAULT_IDENTITY_MAP_CAPACITY

See Also:

Constant Field Values

messageClass

protected final Class<T> messageClass

schema

protected final org.apache.avro.Schema schema

schemaId

protected final int schemaId

schemaName

protected final String schemaName

serializer

protected final io.confluent.kafka.serializers.KafkaAvroSerializer serializer

encoder

protected final org.apache.avro.message.RawMessageEncoder<T> encoder

client

protected final io.confluent.kafka.schemaregistry.client.SchemaRegistryClient client

Constructor Detail

AvroConfluentCodec

public AvroConfluentCodec(Class<T> messageClass,
                          String schemaRegistryUrls)

Create an AvroConfluent codec

Parameters:

messageClass - the class to encode and decode

schemaRegistryUrls - a comma separated list of Confluent Schema Registry URL

Method Detail

getName

public String getName()

Description copied from interface: Codec

Returns the codec name

Specified by:

getName in interface Codec<T>

encode

public byte[] encode(T object)

Description copied from interface: Codec

Encodes the object returns a byte array representation.

Specified by:

encode in interface Codec<T>

decode

public T decode(byte[] data)

Description copied from interface: Codec

Decodes the byte array returns an object.

Specified by:

decode in interface Codec<T>