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 e06c432 commit a933a6bCopy full SHA for a933a6b
ydb/public/sdk/cpp/client/ydb_topic/impl/read_session_impl.ipp
@@ -72,7 +72,7 @@ template<bool UseMigrationProtocol>
72
void TPartitionStreamImpl<UseMigrationProtocol>::ConfirmCreate(TMaybe<ui64> readOffset, TMaybe<ui64> commitOffset) {
73
if (auto sessionShared = CbContext->LockShared()) {
74
if (commitOffset.Defined()) {
75
- SetFirstNotReadOffset(commitOffset.Get());
+ SetFirstNotReadOffset(*commitOffset);
76
}
77
sessionShared->ConfirmPartitionStreamCreate(this, readOffset, commitOffset);
78
0 commit comments