Related to #2 - we need to have the ability to set a configmap as needing to be processed sometime in the future (scheduled processing) in case the broker is unavailable.
Suggestion - add a label indicating the need for reprocessing, with a value of some future time - if unable to reprocess, then update it with the log time.