Hi To achieve exactly once processing for my aggregates, wouldn’t it be enough if I maintain the latest offset processed for the aggregate and check against that offset when messages are replayed on recovery? Am I missing something here?
Thanks Regards Sab
