Skip to content

Commit

Permalink
Merge edb591f into 0378eff
Browse files Browse the repository at this point in the history
  • Loading branch information
nshestakov authored Mar 6, 2024
2 parents 0378eff + edb591f commit 3324d00
Showing 1 changed file with 0 additions and 6 deletions.
6 changes: 0 additions & 6 deletions ydb/services/lib/actors/pq_schema_actor.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -136,12 +136,6 @@ namespace NKikimr::NGRpcProxy::V1 {
}

if (rr.important()) {
if (AppData(ctx)->PQConfig.GetTopicsAreFirstClassCitizen()) {
return TMsgPqCodes(
TStringBuilder() << "important flag is forbiden for consumer " << rr.consumer_name(),
Ydb::PersQueue::ErrorCode::VALIDATION_ERROR
);
}
config->MutablePartitionConfig()->AddImportantClientId(consumerName);
}

Expand Down

0 comments on commit 3324d00

Please sign in to comment.