fix

niksaveliev · niksaveliev · commit 6d70f34928e3 · 2024-10-14T09:50:26.000Z
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);

Original file line number	Diff line number	Diff line change
`@@ -1665,8 +1665,8 @@ namespace NKikimr::NDataStreams::V1 {`
`1665`	`1665`	`record->set_partition_key(r.GetPartitionKey());`
`1666`	`1666`	`record->set_sequence_number(std::to_string(r.GetOffset()).c_str());`
`1667`	`1667`
`1668`		`- if (!proto.has_codec()) {`
`1669`		`- proto.set_codec(NPersQueueCommon::RAW);`
	`1668`	`+ if (proto.GetCodec() > 0) {`
	`1669`	`+ record->set_codec(proto.GetCodec() + 1);`
`1670`	`1670`	`}`
`1671`	`1671`
`1672`	`1672`	`record->set_codec(proto.GetCodec() + 1);`