Commit 5e960503 authored by Tobias Steiner's avatar Tobias Steiner
Browse files

Set streamer to object mode

parent 664f5bf5
......@@ -32,7 +32,7 @@ kafka.init().then(() => {
* pipe the stream from kafka fo neo4j
*/
consumer
.pipe(new Neo4jStreamWriter({}, driver, core));
.pipe(new Neo4jStreamWriter({objectMode: true}, driver, core));
consumer.on('data', () => {
core.getReporter().setDataIn(1);
......
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