Add replay support to the base consumer
Validate replayed messages when tailing.