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