@Test
public void buildRecordsInvalidJson() throws ValidationException {

    thrown.expect( ValidationException.class );
    thrown.expectMessage("Error while parsing payload");
    buildRecords("myTopic", Buffer.buffer("notValidJson"));
}