Commit 215ff526 authored by Tobias Steiner's avatar Tobias Steiner
Browse files

Call the consumer after registering a data handler

parent 237447ca
...@@ -35,7 +35,6 @@ kafka.init().then(() => { ...@@ -35,7 +35,6 @@ kafka.init().then(() => {
// start consuming // start consuming
consumer.consume(1); consumer.consume(1);
}; };
next();
/** /**
* On data, write stuff to neo4j * On data, write stuff to neo4j
...@@ -55,6 +54,7 @@ kafka.init().then(() => { ...@@ -55,6 +54,7 @@ kafka.init().then(() => {
// next(); // next();
}); });
}); });
next();
}); });
}, (err) => { }, (err) => {
core.getLogger().error('Error while connecting to kafka'); core.getLogger().error('Error while connecting to kafka');
......
Markdown is supported
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