@Test
public void getCamusHeadersOldToNew() {

    MyTask myTask = new MyTask();
    GenericRecord inHdr = getOldHeader();
    GenericData.Record outHdr = myTask.getCamusHeaders(inHdr, getHeaderSchema(), 21L);
    assertEquals("testId", outHdr.get("id").toString());
    assertEquals(99L, ((Long)outHdr.get("time")).longValue());
    assertEquals(21L, ((Long)outHdr.get("created")).longValue());
}