It may happen that records processing threads are not shut down by time when engine close() method returned. Also thread managing offset backing store is not closed.