Add logLevel to RetryConfiguration (#15)

Trendyol · Jul 4, 2023 · d0d767e · d0d767e
1 parent 77e87d0
commit d0d767e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/consumer_config.go b/consumer_config.go
@@ -4,6 +4,7 @@ import (
  "time"
 
  kcronsumer "github.com/Trendyol/kafka-cronsumer/pkg/kafka"
+ lcronsumer "github.com/Trendyol/kafka-cronsumer/pkg/logger"
 
  "github.com/segmentio/kafka-go"
 )
@@ -54,7 +55,7 @@ func (cfg *ConsumerConfig) newCronsumerConfig() *kcronsumer.Config {
  StartOffset: kcronsumer.ToStringOffset(cfg.Reader.StartOffset),
  RetentionTime: cfg.Reader.RetentionTime,
  },
- LogLevel: "info",
+ LogLevel: lcronsumer.Level(cfg.RetryConfiguration.LogLevel),
  }
 
  if !cfg.RetryConfiguration.SASL.IsEmpty() {
@@ -96,6 +97,7 @@ type RetryConfiguration struct {
  Brokers []string
  MaxRetry int
  WorkDuration time.Duration
+ LogLevel LogLevel
 }
 
 type BatchConfiguration struct {