A distributed data fan-out and transformation engine built in Java 17 that efficiently reads records from various source formats and distributes them across multiple specialized sinks with ...