diff --git a/node/example/sample-deaggregation.js b/node/example/sample-deaggregation.js index 085dc6f..6f6ac9c 100644 --- a/node/example/sample-deaggregation.js +++ b/node/example/sample-deaggregation.js @@ -39,7 +39,7 @@ var handleNoProcess = function(event, callback) { noProcessReason = "Event contains no Data"; } if (event.Records[0].eventSource !== "aws:kinesis") { - noProcessReason = "Invalid Event Source " + event.eventSource; + noProcessReason = "Invalid Event Source " + event.Records[0].eventSource; } if (event.Records[0].kinesis.kinesisSchemaVersion !== "1.0") { noProcessReason = "Unsupported Event Schema Version " + event.Records[0].kinesis.kinesisSchemaVersion;