@Test
  public void convertWithAvroBytesConverter() throws SerDeException {
    // Since the serialized version was created by Confluent,
    // let's remove the first five bytes to get the actual message.
    int recordLength = simpleRecordConfluentBytes.length;
    byte[] simpleRecordWithNoOffset = Arrays.copyOfRange(simpleRecordConfluentBytes, 5, recordLength);

    Properties tbl = new Properties();
    tbl.setProperty(AvroSerdeUtils.AvroTableProperties.AVRO_SERDE_TYPE.getPropName(), "NONE");

    runConversionTest(tbl, simpleRecordWithNoOffset);
  }
Tests the default case of no skipped bytes per record works properly.
kafka-handler/src/test/org/apache/hadoop/hive/kafka/AvroBytesConverterTest.java