Commit 6de96ac7 authored by Tobias Steiner's avatar Tobias Steiner
Browse files

Get kafka once

parent 11729947
......@@ -16,8 +16,8 @@ const linker = new Linker(core.getNconf(), core.getNconf(), core.getUriBuilder()
*/
const kafka = core.getKafkaAvro();
kafka.init().then(() => {
core.getKafkaAvro().getConsumer().then((consumer) => {
consumer.connect();
kafka.getConsumer().then(async (consumer) => {
await consumer.connect();
/**
* Get next from kafka
......
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