fix

ydb-platform · Oct 14, 2024 · 6d70f34 · 6d70f34
1 parent 8de431e
commit 6d70f34
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/ydb/services/datastreams/datastreams_proxy.cpp b/ydb/services/datastreams/datastreams_proxy.cpp
@@ -1665,8 +1665,8 @@ namespace NKikimr::NDataStreams::V1 {
                 record->set_partition_key(r.GetPartitionKey());
                 record->set_sequence_number(std::to_string(r.GetOffset()).c_str());
 
-                if (!proto.has_codec()) {
-                    proto.set_codec(NPersQueueCommon::RAW);
+                if (proto.GetCodec() > 0) {
+                    record->set_codec(proto.GetCodec() + 1);
                 }
 
                 record->set_codec(proto.GetCodec() + 1);