diff --git a/flow/connectors/eventhub/hub_batches.go b/flow/connectors/eventhub/hub_batches.go index 1cde338d9c..d6b0396056 100644 --- a/flow/connectors/eventhub/hub_batches.go +++ b/flow/connectors/eventhub/hub_batches.go @@ -53,7 +53,7 @@ func (h *HubBatches) AddEvent( if retryForBatchSizeExceed { // if we are already retrying, then we should just return the error // as we have already tried to send the event to the batch. - return err + return fmt.Errorf("[retry-failed] event too large to add to batch: %v", err) } // if the event is too large, send the current batch and