EventMachine framework for an Avro TCP service