@Test
public void buildRecordsInvalidHeadersValueType() throws ValidationException {

    thrown.expect( ValidationException.class );
    thrown.expectMessage("Property 'headers' must be of type JsonObject holding String values only");
    buildRecords("myTopic", Buffer.buffer("{\"records\": [{\"value\": {},\"headers\": {\"key\": 555}}]}"));
}