Provide a multi-threaded implementation of the framework that reads files, parses records, and consumes records in a multi-threaded manner.