@Test
  public void convertWithCustomAvroSkipBytesConverter() throws SerDeException {
    Integer offset = 2;
    // Remove all but two bytes of the five byte offset which Confluent adds,
    // to simulate a message with only 2 bytes in front of each message.
    int recordLength = simpleRecordConfluentBytes.length;
    byte[] simpleRecordAsOffsetBytes = Arrays.copyOfRange(simpleRecordConfluentBytes, 5 - offset, recordLength);

    Properties tbl = new Properties();
    tbl.setProperty(AvroSerdeUtils.AvroTableProperties.AVRO_SERDE_TYPE.getPropName(), "SKIP");
    tbl.setProperty(AvroSerdeUtils.AvroTableProperties.AVRO_SERDE_SKIP_BYTES.getPropName(), offset.toString());

    runConversionTest(tbl, simpleRecordAsOffsetBytes);
  }
Tests that the skip converter skips a custom number of bytes properly.
kafka-handler/src/test/org/apache/hadoop/hive/kafka/AvroBytesConverterTest.java