mcohen01 / amazonica

A comprehensive Clojure client for the entire Amazon AWS api.
1.01k stars 202 forks source link

Kinesis: Store next-check per RecordProcessor #454

Closed Limess closed 2 years ago

Limess commented 2 years ago

Avoid using a single atom for multiple record processor.

This also removes the some loop when running mark-checkpoint - I'm unsure what the intent was here or what it was designed to solve so it may be required for some edge case? Edit - I realised this is a basic retry mechanism, I'll add this back.

Fixes https://github.com/mcohen01/amazonica/issues/452