org.apache.kafka.common.errors.SerializationException: Error deserializing key/value for partition event_source.invoices-0 at offset 0. If needed, please seek past the record to continue consumption.
 Caused by: org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id 1
 Caused by: org.apache.avro.AvroTypeException: Found com.q2c.schema.avro.invoice.InvoiceEvents, expecting com.q2c.schema.avro.invoice.InvoiceEvents, missing required field correlationId
 at org.apache.avro.io.ResolvingDecoder.doAction(ResolvingDecoder.java:292)
 at org.apache.avro.io.parsing.Parser.advance(Parser.java:88)

kafka = TestUtils.createServer(kafkaConfig, Time.SYSTEM); // line 77