This project implements a high-throughput, memory-efficient fan-out engine that ingests large input files in a streaming manner and concurrently dispatches each record to multiple downstream sinks ...