fix

ydb-platform · Feb 29, 2024 · 01a27bb · 01a27bb
1 parent 0257895
commit 01a27bb
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 6 deletions.
diff --git a/ydb/services/lib/actors/pq_schema_actor.cpp b/ydb/services/lib/actors/pq_schema_actor.cpp
@@ -133,8 +133,8 @@ namespace NKikimr::NGRpcProxy::V1 {
             config->AddReadRuleVersions(rr.version());
         }
 
-        auto cct = consumer->MutableCodec();
-        auto ct = config->AddConsumerCodecs();
+        auto* cct = consumer->MutableCodec();
+        auto* ct = NPQ::ReadRuleCompatible() ? config->AddConsumerCodecs() : nullptr;
         if (rr.supported_codecs().size() > MAX_SUPPORTED_CODECS_COUNT) {
             return TMsgPqCodes(
                 TStringBuilder() << "supported_codecs count cannot be more than "
@@ -328,8 +328,8 @@ namespace NKikimr::NGRpcProxy::V1 {
             config->AddReadRuleVersions(version);
         }
 
-        auto cct = consumer->MutableCodec();
-        auto ct = config->AddConsumerCodecs();
+        auto* cct = consumer->MutableCodec();
+        auto* ct = NPQ::ReadRuleCompatible() ? config->AddConsumerCodecs() : nullptr;
 
         for(const auto& codec : rr.supported_codecs().codecs()) {
             if ((!Ydb::Topic::Codec_IsValid(codec) && codec < Ydb::Topic::CODEC_CUSTOM) || codec == 0) {
@@ -394,7 +394,7 @@ namespace NKikimr::NGRpcProxy::V1 {
                 config->AddReadRules(readRule);
                 config->AddReadFromTimestampsMs(originalConfig.GetReadFromTimestampsMs(i));
                 config->AddConsumerFormatVersions(originalConfig.GetConsumerFormatVersions(i));
-                auto ct = config->AddConsumerCodecs();
+                auto* ct = config->AddConsumerCodecs();
                 for (size_t j = 0; j < originalConfig.GetConsumerCodecs(i).CodecsSize(); j++) {
                     ct->AddCodecs(originalConfig.GetConsumerCodecs(i).GetCodecs(j));
                     ct->AddIds(originalConfig.GetConsumerCodecs(i).GetIds(j));

diff --git a/ydb/services/persqueue_v1/actors/schema_actors.cpp b/ydb/services/persqueue_v1/actors/schema_actors.cpp
@@ -1016,7 +1016,6 @@ bool TDescribeConsumerActor::ApplyResponse(
         const auto& location = record.GetLocations(i);
         auto* locationResult = Result.mutable_partitions(i)->mutable_partition_location();
         SetPartitionLocation(location, locationResult);
-
     }
     return true;
 }