Commit 25af81cc authored by Tobias Steiner's avatar Tobias Steiner
Browse files

Add some logs and reduce buffering for messages

parent 78c89b1a
......@@ -7,8 +7,9 @@
"config": {
"group.id": "linker",
"socket.keepalive.enable": true,
"enable.auto.commit": true
},
"enable.auto.commit": true,
"queued.max.messages.kbytes": 1000
},s
"topics": {
"topics": ["linker"]
},
......
......@@ -20,12 +20,13 @@ kafka.init().then(() => {
* Get the consumer subscribed to the topic linker
*/
kafka.getConsumer().then(async (consumer) => {
core.getLogger().info('Got consumer, need a connection');
/**
* Wait for connection
*/
await consumer.connect();
core.getLogger().info('Consumer is connected');
/**
* 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