We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b387c23 commit 110fbd6Copy full SHA for 110fbd6
src/init.js
@@ -29,6 +29,8 @@ async function configureKafkaConsumer (handlers) {
29
const consumer = kafka.consumer({ groupId: config.KAFKA_GROUP_ID })
30
31
logger.info("Connecting to Kafka...")
32
+ logger.info(`Kafka options: ${JSON.stringify(options)}`)
33
+ logger.info(`Kafka group ID: ${config.KAFKA_GROUP_ID}`)
34
await consumer.connect()
35
logger.info(`Subscribing to topics: ${_.keys(handlers)}`)
36
await consumer.subscribe({ topics: _.keys(handlers) })
0 commit comments