Package io.simplesource.kafka.serialization.avro.mappers

Class RegistryBasedDomainMapper<V,S extends org.apache.avro.generic.GenericRecord>

java.lang.Object

io.simplesource.kafka.serialization.avro.mappers.RegistryBasedDomainMapper<V,S>

Type Parameters:

V - Base class for all supported domain classes in the registry

S - Avro base serialized class. Most of the cases this will be GenericRecord

All Implemented Interfaces:

GenericMapper<V,S>

public final class RegistryBasedDomainMapper<V,S extends org.apache.avro.generic.GenericRecord>
extends Object
implements GenericMapper<V,S>

Domain mapper implementation using registry for all supported domain-serialized class combinations

Method Summary

Modifier and Type	Method	Description
V	fromGeneric(S serialized)
S	toGeneric(V value)

Methods inherited from class java.lang.Object

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

Method Detail

toGeneric

public S toGeneric(V value)

Specified by:

toGeneric in interface GenericMapper<V,S extends org.apache.avro.generic.GenericRecord>

fromGeneric

public V fromGeneric(S serialized)

Specified by:

fromGeneric in interface GenericMapper<V,S extends org.apache.avro.generic.GenericRecord>