feat: add logs for retry producing with backoff

Trendyol · Dec 28, 2024 · 029fd37 · 029fd37
1 parent dff773b
commit 029fd37
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/batch_consumer.go b/batch_consumer.go
@@ -3,7 +3,6 @@ package kafka
 import (
 	"errors"
 	"fmt"
-	"github.com/gofiber/fiber/v2/log"
 	"time"
 
 	"github.com/prometheus/client_golang/prometheus"
@@ -263,7 +262,7 @@ func (b *batchConsumer) retryBatchWithBackoff(retryableMessages []kcronsumer.Mes
 		if produceErr == nil {
 			return nil
 		}
-		log.Warnf("Error producing message (attempt %d/%d): %v", attempt, 5, produceErr)
+		b.logger.Warnf("Error producing message (attempt %d/%d): %v", attempt, 5, produceErr)
 		time.Sleep((50 * time.Millisecond) * time.Duration(1<<attempt))
 	}
 

diff --git a/consumer.go b/consumer.go
@@ -2,7 +2,6 @@ package kafka
 
 import (
 	"fmt"
-	"github.com/gofiber/fiber/v2/log"
 	"time"
 
 	"github.com/prometheus/client_golang/prometheus"
@@ -175,7 +174,7 @@ func (c *consumer) retryWithBackoff(retryableMsg kcronsumer.Message) error {
 		if produceErr == nil {
 			return nil
 		}
-		log.Warnf("Error producing message (attempt %d/%d): %v", attempt, 5, produceErr)
+		c.logger.Warnf("Error producing message (attempt %d/%d): %v", attempt, 5, produceErr)
 		time.Sleep((50 * time.Millisecond) * time.Duration(1<<attempt))
 	}