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 String
DEFAULT_SCHEMA_REGISTRY_URLS
static String
KEY_MESSAGE_CLASS
static String
KEY_SCHEMA_REGISTRY_URLS
protected String
messageClassName
protected String
schemaRegistryUrls
-
Constructor Summary
Constructors Constructor Description AvroRecordCodecFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods 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.
-
-
-
Field Detail
-
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
-
-
Method Detail
-
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 interfaceCodecFactory
-
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 interfaceCodecFactory
-
-