@Test
public void testExtractPayload_WrongColumnQualifier() {

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