AWS Kinesis: как повторить попытку отправки в поток кинезиса - PullRequest
0 голосов
/ 30 ноября 2018

Я использую java AWS SDK для потребления записей кинезиса по одной за раз. В частности, я пытаюсь использовать использованную запись, чтобы сохранить ее обратно в поток кинезиса.Но что, если запись не может войти в поток кинезиса из-за исключения газа или пропускной способности?Как повторить попытку отправить эту запись обратно в поток kinesis?

Примечание. Я использую putRecord вместо putRecords, поскольку обрабатываю по одной записи за раз

...