From 8684e2b0d61db6bd644829a30eb2ec6abd20723e Mon Sep 17 00:00:00 2001 From: Frostebite Date: Sun, 7 Feb 2021 18:12:41 +0000 Subject: [PATCH] Decode kinesis data --- src/model/aws.js | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/model/aws.js b/src/model/aws.js index dea64c13..aba1bff4 100644 --- a/src/model/aws.js +++ b/src/model/aws.js @@ -144,10 +144,10 @@ class AWS { iterator = records.NextShardIterator; if (records.Records.length > 0) { for (let index = 0; index < records.Records.length; index++) { - const element = records.Records[index].Data; - core.info(Buffer.from(element).toString('utf8')); - core.info(Buffer.from(element, 'base64').toString('utf8')); - core.info(AWS.ab2str(element)); + const record = records.Records[index].Data; + core.info(Buffer.from(record).toString('utf8')); + core.info(Buffer.from(record, 'base64').toString('utf8')); + core.info(AWS.ab2str(record)); } } }