diff --git a/ydb/library/yql/dq/actors/common/retry_queue.h b/ydb/library/yql/dq/actors/common/retry_queue.h
index 69f7d35332d0..dd28f701e0df 100644
--- a/ydb/library/yql/dq/actors/common/retry_queue.h
+++ b/ydb/library/yql/dq/actors/common/retry_queue.h
@@ -189,6 +189,9 @@ class TRetryEventsQueue {
             THolder<T> ev = MakeHolder<T>();
             ev->Record = Event->Record;
             ev->Record.MutableTransportMeta()->SetConfirmedSeqNo(confirmedSeqNo);
+            for (ui64 i = 0; i < Event->GetPayloadCount(); ++i) {
+                ev->AddPayload(TRope(Event->GetPayload(i)));
+            }
             return MakeHolder<NActors::IEventHandle>(Recipient, Sender, ev.Release(), NActors::IEventHandle::FlagTrackDelivery, Cookie);
         }