-
Notifications
You must be signed in to change notification settings - Fork 47
Open
Description
This code is very helpful for understanding how to work with Kinesis Data Streams - thank you!
While sifting through it, I noticed that retries, which controls the ShardReader's back-off is never actually incremented as far as I can tell; this line adds 1 but never saves the incremented value:
kinesis-python/src/kinesis/consumer.py
Line 54 in 2bf3551
| log.debug("Retrying get_records (#%d %ds): %s", self.retries+1, loop_status, exc) |
This should work:
self.retries += 1
log.debug("Retrying get_records (#%d %ds): %s", self.retries, loop_status, exc)Metadata
Metadata
Assignees
Labels
No labels