fix: remove dist tracing comment

Trendyol · Jan 2, 2024 · f5d385a · f5d385a
1 parent b34a942
commit f5d385a
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/consumer_config.go b/consumer_config.go
@@ -169,9 +169,9 @@ func (cfg *ConsumerConfig) newKafkaReader() (Reader, error) {
 
 	reader := kafka.NewReader(readerCfg)
 
-	// if cfg.DistributedTracingEnabled {
-	//	return NewOtelReaderWrapper(cfg, reader)
-	//}
+	if cfg.DistributedTracingEnabled {
+		return NewOtelReaderWrapper(cfg, reader)
+	}
 
 	return NewReaderWrapper(reader), nil
 }