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