Revert kinesis data serialization to 25.2 compatibility

nshestakov · nshestakov · commit 6041276e6276 · 2025-10-01T12:57:11.000Z
diff --git a/ydb/core/persqueue/pqtablet/blob/blob_serialization.cpp b/ydb/core/persqueue/pqtablet/blob/blob_serialization.cpp
@@ -55,7 +55,7 @@ TMessageFlags InitFlags(const TClientBlob& blob) {
     flags.F.HasWriteTimestamp = 1;
     flags.F.HasPartData = !blob.PartData.Empty();
     flags.F.HasUncompressedSize = blob.UncompressedSize != 0;
-    flags.F.HasKinesisData = !blob.PartitionKey.empty() || !blob.ExplicitHashKey.empty();
+    flags.F.HasKinesisData = !blob.PartitionKey.empty();
     return flags;
 }
 

Original file line number	Diff line number	Diff line change
`@@ -55,7 +55,7 @@ TMessageFlags InitFlags(const TClientBlob& blob) {`
`55`	`55`	`flags.F.HasWriteTimestamp = 1;`
`56`	`56`	`flags.F.HasPartData = !blob.PartData.Empty();`
`57`	`57`	`flags.F.HasUncompressedSize = blob.UncompressedSize != 0;`
`58`		`- flags.F.HasKinesisData = !blob.PartitionKey.empty() \|\| !blob.ExplicitHashKey.empty();`
	`58`	`+ flags.F.HasKinesisData = !blob.PartitionKey.empty();`
`59`	`59`	`return flags;`
`60`	`60`	`}`
`61`	`61`