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

Missing handling of unsuccessfully processed records

Open neongazer opened this issue 5 years ago • 0 comments

https://github.com/NerdWalletOSS/kinesis-python/blob/2bf355173de05a38f685df0f5a6000cff9a2076a/src/kinesis/producer.py#L126

By default, failure of individual records within a request does not stop the processing of subsequent records in a boto3 kinesis client put_records() request. This means that a returned records array from put_records() includes both successfully and unsuccessfully processed records. This library is missing detection of unsuccessfully processed records and handling in a subsequent call.

neongazer avatar Jul 27 '20 09:07 neongazer