Hi All, I am using kafka 0.9.0.1 with high level java producer and consumer. I need to handle a case wherein I need to re-consume the already consumed (and processed) messages say for last 5 days (configurable).
Is there any way of achieving the same apart from identifying the offsets for the partition (for given topic) and process the same? For the records, I am not storing the offsets processed. Thanks
