NerdWalletOSS kinesis-python issues

NerdWalletOSS / kinesis-python

Low level, multiprocessing based AWS Kinesis producer & consumer library

Other

117 stars 50 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

Bump versions

#36 matgoebl closed 6 months ago
0
Is this project dead?

#35 MacHu-GWU opened 11 months ago
0
Create opslevel.yml

#34 alvaroqueirozna opened 1 year ago
0
How to have multiple consumers?

#33 jrmeland opened 1 year ago
0
Support using enhanced fan-out for consumer

#32 givenday opened 1 year ago
0
ShardReader retry does not back-off

#31 inventhouse opened 2 years ago
1
feat: Configurable endpoint_url

#30 skolsuper opened 3 years ago
0
Custom consumer state check-pointing

#29 kevinballard opened 3 years ago
0
Custom endpoint_url and 'ShardId'

#28 nicholasball opened 3 years ago
1
Custom endpoint_url and 'ShardId'

#27 nicholasball closed 3 years ago
1
Pass-in and override endpoint_url in boto3 Kinesis client and DynamoDB resource

#26 nicholasball opened 4 years ago
1
Missing handling of unsuccessfully processed records

#25 neongazer opened 4 years ago
0
Use of offpsring eventually leads to too many open files if there are closed shards

#24 jeffglover opened 5 years ago
0
Add shutdown method to producer for clean exit

#23 lweehuizen-rbx closed 4 years ago
1
Add support to "AT_TIMESTAMP" ShardIteratorType

#22 M0dM opened 5 years ago
2
Python 3.7 port

#21 jasonbot closed 5 years ago
1
DynamoDB.should_start_shard_reader is missing?

#20 mabaasit closed 1 year ago
0
Custom checkpointing

#19 kokes closed 5 years ago
1
further explaination needs reader_sleep_time=12

#18 ahmadjd94 closed 5 years ago
1
Cannot be used from within Celery

#17 danielcohenlive opened 6 years ago
0
No obvious way to use VPC Interface endpoint

#16 madsenwattiq opened 6 years ago
1
Added improvements, better error handling, max queue size to prevent memory runaway, etc.

#15 keithjjones closed 3 years ago
11
AttributeError: Can't pickle local object 'Subprocess.start.<locals>.bootstrap

#14 houdinisparks opened 6 years ago
7
Update MAX_COUNT to be the maximum number of allowed by PutRecords

#13 langseth closed 5 years ago
3
Correct sizeof implementation

#12 borgstrom closed 6 years ago
1
Switch to .rst for README

#11 borgstrom closed 6 years ago
1
Packaging improvements / More producer control

#10 borgstrom closed 6 years ago
1
No module named state

#9 jaferrer closed 7 years ago
1
Support python3 by importing queue as Queue.

#8 hengfengli closed 6 years ago
3
No such file or directory: 'VERSION'

#7 hengfengli closed 6 years ago
3
ModuleNotFoundError in Python3

#6 max-lg closed 6 years ago
1
Ability to specify partition key

#5 burkaygur closed 6 years ago
0
Send at most 1000 messages per buffer cycle

#4 borgstrom closed 7 years ago
0
Producer loop ignores max # of messages per put_records

#3 itamarla opened 7 years ago
1
Add locking and state

#2 borgstrom closed 7 years ago
0
Add retries for throttling on get_records

#1 borgstrom closed 7 years ago
0