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!

已提問 2 年前檢視次數 75 次
沒有答案

您尚未登入。 登入 去張貼答案。

一個好的回答可以清楚地回答問題並提供建設性的意見回饋,同時有助於提問者的專業成長。

回答問題指南