Suppression decorateur

etf1 · Nov 21, 2023 · a5de566 · a5de566
1 parent 737cb35
commit a5de566
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/internal/service/kafka.go b/internal/service/kafka.go
@@ -49,10 +49,12 @@ func (container *Container) getKafkaBaseClient() kafka.Client {
 	originalKafkaProducer := container.GetKafkaProducer()
 	var kafkaProducer kafka.KafkaProducer = originalKafkaProducer
 
-	if container.Cfg.OtelCollectorEndpoint != "" {
-		// In case OpenTelemetry endpoint is enabled, decorate the Kafka producer.
-		kafkaProducer = container.decorateKafkaClientWithOpenTelemetry(originalKafkaProducer)
-	}
+	/*
+		if container.Cfg.OtelCollectorEndpoint != "" {
+			// In case OpenTelemetry endpoint is enabled, decorate the Kafka producer.
+			kafkaProducer = container.decorateKafkaClientWithOpenTelemetry(originalKafkaProducer)
+		}
+	*/
 
 	return kafka.NewClient(kafkaProducer)
 }