Add lag monitoring

[derekjn]

Something like a view over a function call that compares the latest Kafka offsets to the consumer's processed offsets.