feat: set log_level confluent-kafka-go

topfreegames · Jun 15, 2023 · 98d779d · 98d779d
1 parent a1e9028
commit 98d779d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/extensions/kafka_consumer.go b/extensions/kafka_consumer.go
@@ -151,6 +151,7 @@ func (q *KafkaConsumer) configureConsumer(client interfaces.KafkaConsumerClient)
 				"auto.offset.reset":  q.OffsetResetStrategy,
 				"auto.commit.enable": true,
 			},
+			"log_level": int(uint32(q.logger.Level()) + 2),
 		})
 		if err != nil {
 			l.WithError(err).Error("error configuring kafka queue")