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

    final List<KafkaProducerRecord<String, String>> records =
            buildRecords("myTopic", Buffer.buffer("{\"records\": []}"));
    context.assertTrue(records.isEmpty());
}