DeadLetterTopic field added to RetryConfiguration. (#35)

Trendyol · Sep 11, 2023 · a24d3e5 · a24d3e5
1 parent 11ed120
commit a24d3e5
Showing 1 changed file with 12 additions and 10 deletions.
diff --git a/consumer_config.go b/consumer_config.go
@@ -48,6 +48,7 @@ func (cfg *ConsumerConfig) newCronsumerConfig() *kcronsumer.Config {
 			ClientID:          cfg.ClientID,
 			GroupID:           cfg.Reader.GroupID,
 			Topic:             cfg.RetryConfiguration.Topic,
+			DeadLetterTopic:   cfg.RetryConfiguration.DeadLetterTopic,
 			Cron:              cfg.RetryConfiguration.StartTimeCron,
 			Duration:          cfg.RetryConfiguration.WorkDuration,
 			Concurrency:       cfg.Concurrency,
@@ -95,16 +96,17 @@ type MetricConfiguration struct {
 }
 
 type RetryConfiguration struct {
-	SASL          *SASLConfig
-	TLS           *TLSConfig
-	ClientID      string
-	StartTimeCron string
-	Topic         string
-	Rack          string
-	Brokers       []string
-	MaxRetry      int
-	WorkDuration  time.Duration
-	LogLevel      LogLevel
+	SASL            *SASLConfig
+	TLS             *TLSConfig
+	ClientID        string
+	StartTimeCron   string
+	Topic           string
+	DeadLetterTopic string
+	Rack            string
+	Brokers         []string
+	MaxRetry        int
+	WorkDuration    time.Duration
+	LogLevel        LogLevel
 }
 
 type BatchConfiguration struct {