@Test
public void buildRecordsInvalidKeyType() throws ValidationException {

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