Package org.nuxeo.runtime.codec

Class AvroRecordCodecFactory

java.lang.Object

org.nuxeo.runtime.codec.AvroRecordCodecFactory

All Implemented Interfaces:

CodecFactory

public class AvroRecordCodecFactory
extends Object
implements CodecFactory

Factory to generate Record compliant with Confluent Avro, ready to be used by ksqlDB.

Since:

11.4

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_SCHEMA_REGISTRY_URLS
static final String	KEY_MESSAGE_CLASS
static final String	KEY_SCHEMA_REGISTRY_URLS
protected String	messageClassName
protected String	schemaRegistryUrls

Constructor Summary

Constructors

Constructor	Description
AvroRecordCodecFactory()

Method Summary

Modifier and Type	Method	Description
void	init(Map<String,String> options)	Initializes the codec factory using a map of options.
<T> Codec<T>	newCodec(Class<T> objectClass)	Returns a codec object enables to encode/decode object ot class T.

Methods inherited from class java.lang.Object

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

Field Details

KEY_SCHEMA_REGISTRY_URLS

public static final String KEY_SCHEMA_REGISTRY_URLS

See Also:

• Constant Field Values

DEFAULT_SCHEMA_REGISTRY_URLS

public static final String DEFAULT_SCHEMA_REGISTRY_URLS

See Also:

• Constant Field Values

KEY_MESSAGE_CLASS

public static final String KEY_MESSAGE_CLASS

See Also:

• Constant Field Values

messageClassName

protected String messageClassName

schemaRegistryUrls

protected String schemaRegistryUrls

Constructor Details

AvroRecordCodecFactory

public AvroRecordCodecFactory()

Method Details

init

public void init(Map<String,String> options)

Description copied from interface: CodecFactory

Initializes the codec factory using a map of options.

Specified by:

init in interface CodecFactory

newCodec

public <T> Codec<T> newCodec(Class<T> objectClass)

Description copied from interface: CodecFactory

Returns a codec object enables to encode/decode object ot class T.

Specified by:

newCodec in interface CodecFactory