From f5d385a2fcdacfb03a966158b0d816a89882181a Mon Sep 17 00:00:00 2001 From: Abdulsametileri Date: Tue, 2 Jan 2024 18:21:07 +0300 Subject: [PATCH] fix: remove dist tracing comment --- consumer_config.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/consumer_config.go b/consumer_config.go index 415083b..9c33450 100644 --- 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 }