@Test
public void buildRecordsValidNoKeyNoHeaders(TestContext context) throws ValidationException {

    JsonObject payload = buildPayload(null, null);
    final List<KafkaProducerRecord<String, String>> records =
            buildRecords("myTopic", Buffer.buffer(payload.encode()));
    context.assertFalse(records.isEmpty());
    context.assertEquals(1, records.size());
    context.assertEquals("myTopic", records.get(0).topic());
    context.assertNull(records.get(0).key());
    context.assertEquals(payload.getJsonArray("records").getJsonObject(0).getJsonObject("value").encode(),
            records.get(0).value());
    context.assertTrue(records.get(0).headers().isEmpty());
}