Skip to content

Commit

Permalink
feature: fix golang ci errors
Browse files Browse the repository at this point in the history
  • Loading branch information
mhmtszr committed Dec 2, 2023
1 parent 6ece356 commit d5498b7
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 3 deletions.
3 changes: 2 additions & 1 deletion consumer.go
Original file line number Diff line number Diff line change
@@ -1,9 +1,10 @@
package kafka

import (
kcronsumer "github.com/Trendyol/kafka-cronsumer/pkg/kafka"
"sync"
"time"

kcronsumer "github.com/Trendyol/kafka-cronsumer/pkg/kafka"
)

type consumer struct {
Expand Down
2 changes: 1 addition & 1 deletion consumer_config.go
Original file line number Diff line number Diff line change
Expand Up @@ -166,7 +166,7 @@ func (cfg *ConsumerConfig) newKafkaReader() (Reader, error) {

reader := kafka.NewReader(readerCfg)

//if cfg.DistributedTracingEnabled {
// if cfg.DistributedTracingEnabled {
// return NewOtelReaderWrapper(cfg, reader)
//}

Expand Down
2 changes: 1 addition & 1 deletion otel_reader_wrapper.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package kafka

//type otelReaderWrapper struct {
// type otelReaderWrapper struct {
// r *otelkafkakonsumer.Reader
//}
//
Expand Down

0 comments on commit d5498b7

Please sign in to comment.