We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 07f9e3c commit f6cd127Copy full SHA for f6cd127
ydb/core/fq/libs/row_dispatcher/topic_session.cpp
@@ -609,10 +609,15 @@ void TTopicSession::SendData(TClientsInfo& info) {
609
LOG_ROW_DISPATCHER_TRACE("Buffer empty");
610
}
611
612
+ if (!info.NextMessageOffset) {
613
+ LOG_ROW_DISPATCHER_ERROR("Try SendData() without NextMessageOffset, " << info.ReadActorId
614
+ << " unread " << info.UnreadBytes << " DataArrivedSent " << info.DataArrivedSent);
615
+ return;
616
+ }
617
+
618
do {
619
auto event = std::make_unique<TEvRowDispatcher::TEvMessageBatch>();
620
event->Record.SetPartitionId(PartitionId);
- Y_ENSURE(info.NextMessageOffset);
621
event->ReadActorId = info.ReadActorId;
622
623
ui64 batchSize = 0;
0 commit comments