From 110fbd69b326edecdb33c59a5e931da0599acdb9 Mon Sep 17 00:00:00 2001 From: Justin Gasper Date: Wed, 14 Aug 2024 13:41:06 +1000 Subject: [PATCH] Debug logging --- src/init.js | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/init.js b/src/init.js index 41e01c6..a3f5b5f 100644 --- a/src/init.js +++ b/src/init.js @@ -29,6 +29,8 @@ async function configureKafkaConsumer (handlers) { const consumer = kafka.consumer({ groupId: config.KAFKA_GROUP_ID }) logger.info("Connecting to Kafka...") + logger.info(`Kafka options: ${JSON.stringify(options)}`) + logger.info(`Kafka group ID: ${config.KAFKA_GROUP_ID}`) await consumer.connect() logger.info(`Subscribing to topics: ${_.keys(handlers)}`) await consumer.subscribe({ topics: _.keys(handlers) })