feat: refactor error message in batch_consumer

Trendyol · Dec 22, 2024 · 4e38c53 · 4e38c53
1 parent 3118740
commit 4e38c53
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/batch_consumer.go b/batch_consumer.go
@@ -242,9 +242,9 @@ func (b *batchConsumer) process(chunkMessages []*Message) {
 
 			if err := b.retryBatchWithBackoff(cronsumerMessages); err != nil {
 				errorMsg := fmt.Sprintf(
-					"Error producing messages to exception/retry topic. Error: %s", err.Error())
+					"Error producing messages to exception/retry topic: %s. Error: %s", b.retryTopic, err.Error())
 				b.logger.Error(errorMsg)
-				panic(err.Error())
+				panic(errorMsg)
 			}
 		}
 	}