Fix bug in "getRecords"

lifion · Apr 29, 2019 · 72eaa66 · 72eaa66
1 parent 8dbae32
commit 72eaa66
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/kinesis-client.js b/lib/kinesis-client.js
@@ -249,7 +249,7 @@ class KinesisClient {
         client
           .getRecords(...args)
           .promise()
-          .then(tapAwsReponse)
+          .then(tapAwsReponse(streamName))
           .catch(err => {
             if (shouldBailRetry(err)) bail(err);
             else {