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!

demandé il y a 2 ans75 vues
Aucune réponse

Vous n'êtes pas connecté. Se connecter pour publier une réponse.

Une bonne réponse répond clairement à la question, contient des commentaires constructifs et encourage le développement professionnel de la personne qui pose la question.

Instructions pour répondre aux questions