Validate consumer attributes: fail on unknown attributes

Author: UgnineSirdis

ydb/services/lib/actors/pq_schema_actor.cpp

@@ -254,6 +254,11 @@ namespace NKikimr::NGRpcProxy::V1 {
                 passwordHash = MD5::Data(pair.second);
                 passwordHash.to_lower();
                 hasPassword = true;
+            } else {
+                TString error = TStringBuilder() << "Consumer attribute " << pair.first << " is not supported";
+                if (error) {
+                    return TMsgPqCodes(error, Ydb::PersQueue::ErrorCode::INVALID_ARGUMENT);
+                }
             }
         }
         if (serviceType.empty()) {
@@ -543,7 +548,7 @@ namespace NKikimr::NGRpcProxy::V1 {
                         return Ydb::StatusIds::BAD_REQUEST;
                     }
                 }
-            }  else if (pair.first == "_message_group_seqno_retention_period_ms") {
+            } else if (pair.first == "_message_group_seqno_retention_period_ms") {
                 partConfig->SetSourceIdLifetimeSeconds(NKikimrPQ::TPartitionConfig().GetSourceIdLifetimeSeconds());
                 if (!pair.second.empty()) {
                     try {