kinesis-python icon indicating copy to clipboard operation
kinesis-python copied to clipboard

Custom consumer state check-pointing

Open kevinballard opened this issue 4 years ago • 0 comments

  • Add the ability to save a custom consumer state along with the log offset, allowing for stateful consumers to stop and resume gracefully
  • Maintains the original API when using KinesisConsumer directly as an iterator
  • Also emit shard_id with the "rich" generator
  • Allow an optional consumer name so that state for multiple consumers of the same stream can exist in the same DynamoDB table
  • Update README examples to Python 3

kevinballard avatar Jun 04 '21 20:06 kevinballard