Refactored out code and created a an applier that will checkpoint (in MySQL) when every commit happens allowing it to resume where it left off as well as replay the binary logs if needed. Also a sample applier implementation that uses the CommitCheckpointingApplier.