This change alters the deleted record loading query to query all
available partitions. The change also adds a consume_after column to
prepare for the implementation of the fair queueing implementation.

Changelog: added