whale2 / async-kinesis-client

Python Kinesis Client library utilising asyncio
MIT License
13 stars 4 forks source link

Add iterator type parameter and bulk put_records #1

Closed whale2 closed 5 years ago

whale2 commented 5 years ago

Add 'shard_iterator_type' and 'iterator_timestamp' parameters to AsyncKinesisConsumer Add 'put_records' method to AsyncKinesisProducer Add tests