diff --git a/CHANGELOG.md b/CHANGELOG.md
new file mode 100644
index 0000000..133940c
--- /dev/null
+++ b/CHANGELOG.md
@@ -0,0 +1,2 @@
+# 1.5.1
+* Fixed bug where only the first event would write to Firehose.
\ No newline at end of file
diff --git a/dist/LambdaStreamToFirehose-1.5.1.zip b/dist/LambdaStreamToFirehose-1.5.1.zip
new file mode 100644
index 0000000..78cd981
Binary files /dev/null and b/dist/LambdaStreamToFirehose-1.5.1.zip differ
diff --git a/index.js b/index.js
index f258172..761c858 100644
--- a/index.js
+++ b/index.js
@@ -41,7 +41,7 @@ var useTransformer;
 function setTransformer(transformer) {
     useTransformer = transformer
 }
-exports.setTransformer = setTransformer
+exports.setTransformer = setTransformer;
 
 /*
  * Configure destination router. By default all records route to the configured
@@ -57,7 +57,7 @@ var useRouter = router.defaultRouting.bind(undefined);
 function setRouter(router) {
     useRouter = router
 }
-exports.setRouter = setRouter
+exports.setRouter = setRouter;
 // example for using routing based on messages attributes
 // var attributeMap = {
 // "binaryValue" : {
@@ -137,6 +137,8 @@ function init(callback) {
 		callback(null);
 	    }
 	});
+    } else {
+      callback(null);
     }
 }
 exports.init = init;
diff --git a/package.json b/package.json
index 4fdafb4..3ac8b1f 100644
--- a/package.json
+++ b/package.json
@@ -1,7 +1,7 @@
 {
 	"name": "lambda-stream-to-firehose",
 	"description": "An AWS Lambda function that forwards data from a Kinesis or DynamoDB Update Stream to a Kinesis Firehose Delivery Stream",
-	"version": "1.5.0",
+	"version": "1.5.1",
 	"dependencies": 
 	{
 		"async": "2.1.4",