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