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!

preguntada hace 2 años75 visualizaciones
No hay respuestas

No has iniciado sesión. Iniciar sesión para publicar una respuesta.

Una buena respuesta responde claramente a la pregunta, proporciona comentarios constructivos y fomenta el crecimiento profesional en la persona que hace la pregunta.

Pautas para responder preguntas