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 :
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