diff options
| author | ilnaz <ilnaz@ydb.tech> | 2022-09-09 19:21:30 +0300 |
|---|---|---|
| committer | ilnaz <ilnaz@ydb.tech> | 2022-09-09 19:21:30 +0300 |
| commit | 6ef941e4adcfcf871e004675e27442a91d82fb82 (patch) | |
| tree | cce006097117b1fe76791fdb99552ce8e8d0c0e5 | |
| parent | d27978150581c97592110c7bcbf00e45bc2e4cdd (diff) | |
| download | ydb-6ef941e4adcfcf871e004675e27442a91d82fb82.tar.gz | |
Fixed metering mode check
| -rw-r--r-- | ydb/services/persqueue_v1/actors/read_session_actor.ipp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/ydb/services/persqueue_v1/actors/read_session_actor.ipp b/ydb/services/persqueue_v1/actors/read_session_actor.ipp index a71056406a..4a5da33c3a 100644 --- a/ydb/services/persqueue_v1/actors/read_session_actor.ipp +++ b/ydb/services/persqueue_v1/actors/read_session_actor.ipp @@ -951,7 +951,8 @@ void TReadSessionActor<UseMigrationProtocol>::Handle(TEvPQProxy::TEvAuthResultOk << t.TopicNameConverter->GetPrintableString() << "' found", PersQueue::ErrorCode::BAD_REQUEST, ctx ); - } else if (it->second.MeteringMode != *GetMeteringMode()) { + } + if (t.MeteringMode != *GetMeteringMode()) { return CloseSession( TStringBuilder() << "Metering mode of topic: " << name << " has been changed", PersQueue::ErrorCode::OVERLOAD, ctx |