Throw error for debuging

src/index.ts

@@ -55,7 +55,8 @@ kafka.init().then(() => {
         next();
       }, (error) => {
         core.getLogger().error('Could not save data to neo4j ' + JSON.stringify(error));
-        next();
+        throw error;
+        // next();
       });
     });
   });