Commit 240b00fc authored by Tobias Steiner's avatar Tobias Steiner
Browse files

Add log for consuming data

parent b98bd902
......@@ -43,6 +43,7 @@ kafka.init().then(() => {
* On data, write stuff to neo4j
*/
consumer.on('data', (rawData) => {
core.getLogger().info('Consumed some data');
clearInterval(index);
core.getReporter().setDataIn(1);
// create new node
......
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