public class AvroReflectDatumBackedKafkaEncoder<T> extends AvroDatumSupport<T> implements kafka.serializer.Encoder<T>
Constructor and Description |
---|
AvroReflectDatumBackedKafkaEncoder(java.lang.Class<T> clazz) |
Modifier and Type | Method and Description |
---|---|
byte[] |
toBytes(T source) |
fromBytes, toBytes