AvroConfluentCodec (Nuxeo 2021.70.4 API Documentation)

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	Description
`protected io.confluent.kafka.schemaregistry.client.SchemaRegistryClient`	`client`
`protected static int`	`DEFAULT_IDENTITY_MAP_CAPACITY`
`protected org.apache.avro.message.RawMessageEncoder<T>`	`encoder`
`static int`	`ID_SIZE`
`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 Description

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

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	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
`static io.confluent.kafka.schemaregistry.client.SchemaRegistryClient`	`getRegistryClient(String schemaRegistryUrls)`

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
```
public static final byte MAGIC_BYTE
```
See Also:

Constant Field Values

ID_SIZE
```
public 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
- getRegistryClient
```
public static io.confluent.kafka.schemaregistry.client.SchemaRegistryClient getRegistryClient(String schemaRegistryUrls)
```
- 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>