public class AvroDeserializer extends AvroSerDe implements org.apache.kafka.common.serialization.Deserializer<java.lang.Object>
Modifier and Type | Class and Description |
---|---|
protected static class |
AvroDeserializer.AvroDeserializerInputStream |
isKey, keySubjectName, schemaRegistrationStrategy, valueSubjectName
Constructor and Description |
---|
AvroDeserializer() |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
deserialize(java.lang.String subject,
byte[] data) |