Add avro schema generator for parsing incoming avro records from Kafka