derekjn opened this issue 8 years ago · 0 comments
Something like a view over a function call that compares the latest Kafka offsets to the consumer's processed offsets.