We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5b7b18a commit 54cd8d5Copy full SHA for 54cd8d5
src/consumer.js
@@ -155,7 +155,7 @@ async function setupKafkaConsumer() {
155
await consumer.init(strategies)
156
logger.info('Initialized kafka consumer')
157
healthcheck.init([check])
158
- kafkaService.init().catch((e) => {
+ kafkaService.init().catch(async (e) => {
159
logger.error(`Kafka producer intialization error: "${e}"`)
160
await callposttoslack(`error-sync: postgres-ifx-processor : consumer Kafka producer intialization : ${e}`)
161
terminate()
0 commit comments