During record processing the commitOffsets method can be periodically called.  The underlying storage mechanism can return a future that may get interrupted.  The InterruptedException is currently caught but not propagated to the rest of the application.  This can result in the engine continuing to run even though the thread has been interrupted/executor has been shutdown.