question: public Future < ReplDBMSHeader > flush ( String eventId ) throws InterruptedException , ReplicatorException { logger . info ( "Scheduling pipeline flush on event ID: " + eventId ) ; return watchForProcessedEventId ( eventId ) ; }
target:  Wait until the log reaches at least a particular event ID.