Accumulates Avro datum received via RabbitMQ messages and stores them in Avro container files - View it on GitHub