NerdWalletOSS/kinesis-python
Low level, multiprocessing based AWS Kinesis producer & consumer library
PythonNOASSERTION
Issues
- 0
Is this project dead?
#35 opened by MacHu-GWU - 7
AttributeError: Can't pickle local object 'Subprocess.start.<locals>.bootstrap
#14 opened by houdinisparks - 0
DynamoDB.should_start_shard_reader is missing?
#20 opened by mabaasit - 0
How to have multiple consumers?
#33 opened by jrmeland - 0
Support using enhanced fan-out for consumer
#32 opened by givenday - 1
ShardReader retry does not back-off
#31 opened by inventhouse - 1
Pass-in and override endpoint_url in boto3 Kinesis client and DynamoDB resource
#26 opened by nicholasball - 0
- 0
Use of offpsring eventually leads to too many open files if there are closed shards
#24 opened by jeffglover - 1
No obvious way to use VPC Interface endpoint
#16 opened by madsenwattiq - 1
further explaination needs reader_sleep_time=12
#18 opened by ahmadjd94 - 1
Custom checkpointing
#19 opened by kokes - 0
Cannot be used from within Celery
#17 opened by danielcohenlive - 3
No such file or directory: 'VERSION'
#7 opened by hengfengli - 0
Ability to specify partition key
#5 opened by burkaygur - 1
ModuleNotFoundError in Python3
#6 opened by max-lg - 1
No module named state
#9 opened by jaferrer - 1