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 StringDEFAULT_SCHEMA_REGISTRY_URLSstatic StringKEY_MESSAGE_CLASSstatic StringKEY_SCHEMA_REGISTRY_URLSprotected StringmessageClassNameprotected StringschemaRegistryUrls
-
Constructor Summary
Constructors Constructor Description AvroRecordCodecFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidinit(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:CodecFactoryInitializes the codec factory using a map of options.- Specified by:
initin interfaceCodecFactory
-
newCodec
public <T> Codec<T> newCodec(Class<T> objectClass)
Description copied from interface:CodecFactoryReturns a codec object enables to encode/decode object ot class T.- Specified by:
newCodecin interfaceCodecFactory
-
-