What are the best ways to replay a portion of a topic in the past?

I'm using Kafka to process a real-time data stream. Suppose I discover that
all data inside of a six-hour window one day ago was incorrectly processed.

Since I'm checkpointing offsets in an external database, I can create a new
consumer group and then restore the offsets from the start of the error
window to that group. But how do I get my consumer to stop processing at
the end of the error window?

More generally, how do I reprocess an arbitrary interval of data within a
topic?

Reply via email to