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!

asked 2 years ago74 views
No Answers

You are not logged in. Log in to post an answer.

A good answer clearly answers the question and provides constructive feedback and encourages professional growth in the question asker.

Guidelines for Answering Questions