@Override
    Decoder getDecoder(byte[] value) throws SerDeException {
      try {
        return DecoderFactory.get().binaryDecoder(value, this.skipBytes, value.length - this.skipBytes, null);
      } catch (ArrayIndexOutOfBoundsException e) {
        throw new SerDeException("Skip bytes value is larger than the message length.", e);
      }
    }
Avro converter which skips the first @skipBytes of each message.

This may be needed for various serializers, such as the Confluent Avro serializer, which uses the first five
bytes to indicate a magic byte, as well as a four byte schema ID.
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaSerDe.java