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 54d0643 commit d6d0e6bCopy full SHA for d6d0e6b
ydb/core/tx/replication/service/topic_reader.cpp
@@ -84,8 +84,9 @@ class TRemoteTopicReader: public TActor<TRemoteTopicReader> {
84
void Handle(TEvWorker::TEvCommit::TPtr& ev) {
85
LOG_D("Handle " << ev->Get()->ToString());
86
87
- Y_ABORT_UNLESS(YdbProxy);
88
- Y_ABORT_UNLESS(ReadSessionId);
+ if (!YdbProxy || !ReadSessionId) {
+ return Leave(TEvWorker::TEvGone::UNAVAILABLE);
89
+ }
90
91
auto settings = NYdb::NTopic::TCommitOffsetSettings()
92
.ReadSessionId(ReadSessionId);
0 commit comments