bulker: retry_consumer: skip overly large messages

jitsucom · Nov 28, 2024 · 391da94 · 391da94
1 parent 0b182a6
commit 391da94
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/bulkerapp/app/retry_consumer.go b/bulkerapp/app/retry_consumer.go
@@ -179,7 +179,8 @@ func (rc *RetryConsumer) processBatchImpl(_ *Destination, _, _, retryBatchSize i
 			Value:          message.Value,
 		}, nil)
 		if err != nil {
-			return counters, state, false, fmt.Errorf("failed to put message to producer: %v", err)
+			rc.Errorf("Failed to put message to producer: %v\nMessage: %s Headers: %+v Key: %v", err, string(message.Value), headers, message.Key)
+			//return counters, state, false, fmt.Errorf("failed to put message to producer: %v", err)
 		}
 		counters.accumulate(singleCount)