Kinesis Broken pipe

0

Hi I reading from Kinesis and writing into dynamodb. While looping through the records, after 2 hours I get : "Exception has occurred. Broken pipe". After doing some research I added the following code :

Aws::SDKOptions options; options.httpOptions.installSigPipeHandler = true; Aws::InitAPI(options);

But this was not successful . I did turn on AWS debugger but no specific error came out of the trace. Here is the line that is bringing the error :

while (shardIterator != "") {

getRecordsRequest.SetShardIterator(shardIterator); Aws::Kinesis::Model::GetRecordsOutcome getRecordsResult = kinesisClient.GetRecords(getRecordsRequest); // <= this line

.....

Could you please help ? Thank!

gefragt vor 2 Jahren75 Aufrufe
Keine Antworten

Du bist nicht angemeldet. Anmelden um eine Antwort zu veröffentlichen.

Eine gute Antwort beantwortet die Frage klar, gibt konstruktives Feedback und fördert die berufliche Weiterentwicklung des Fragenstellers.

Richtlinien für die Beantwortung von Fragen

Relevanter Inhalt