@Test
public void testExtractPayload_WrongColumnFamily() {

    byte[] payload = extractor.extractPayload(TABLE_NAME, new KeyValue(ROW, Bytes.toBytes("wrong family"),
            COLUMN_QUALIFIER, PAYLOAD_DATA));
    assertNull(payload);
}