# CustomAvroDeserializationSchema.java

```
// CustomAvroDeserializationSchema.java
...
public interface CustomAvroDeserializationSchema<T> extends KafkaDeserializationSchema<T> {
    T deserialize(byte[] var1, byte[] var2, String var3, int var4, long var5, long var6) throws IOException;

    default T deserialize(ConsumerRecord<byte[], byte[]> record) throws IOException {
        return this.deserialize(
                (byte[])record.key(),
                (byte[])record.value(),
                record.topic(),
                record.partition(),
                record.offset(),
                record.timestamp()
        );
    }
}
...
```