AVRO source assumes that the incoming data is of type JSON. Implement a way to let the producer know what format the previous vertex is writing in.