Commit 1aa02c30 authored by Tobias Steiner's avatar Tobias Steiner
Browse files

Call next immediately

parent 240b00fc
......@@ -38,6 +38,7 @@ kafka.init().then(() => {
consumer.consume(100);
}, 1);
};
next();
/**
* On data, write stuff to neo4j
......@@ -56,7 +57,6 @@ kafka.init().then(() => {
core.getLogger().error(JSON.stringify(error));
next();
});
next();
});
});
}, (err) => {
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment