diff --git a/extensions/kafka_consumer.go b/extensions/kafka_consumer.go
index c9f5c08..58ce277 100644
--- 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")