Fix crashing on decompression error (#28140)

FloatingCrowbar · web-flow · commit 5dbd26ce2068 · 2025-11-01T15:46:57.000Z
diff --git a/ydb/core/viewer/viewer_topic_data.cpp b/ydb/core/viewer/viewer_topic_data.cpp
@@ -202,7 +202,11 @@ void TTopicData::FillProtoResponse(ui64 maxTotalSize) {
             if (codec == nullptr) {
                 return ReplyAndPassAway(GetHTTPINTERNALERROR("text/plain", "Message decompression failed"));
             }
-            setData(*messageProto, std::move(codec->Decompress(dataChunk.GetData())));
+            try {
+                setData(*messageProto, std::move(codec->Decompress(dataChunk.GetData())));
+            } catch (const std::exception& e) {
+                setData(*messageProto, ">>> Message decompression failed <<<");
+            }
         } else {
             setData(*messageProto, std::move(*dataChunk.MutableData()));
         }

Original file line number	Diff line number	Diff line change
`@@ -202,7 +202,11 @@ void TTopicData::FillProtoResponse(ui64 maxTotalSize) {`
`202`	`202`	`if (codec == nullptr) {`
`203`	`203`	`return ReplyAndPassAway(GetHTTPINTERNALERROR("text/plain", "Message decompression failed"));`
`204`	`204`	`}`
`205`		`- setData(*messageProto, std::move(codec->Decompress(dataChunk.GetData())));`
	`205`	`+ try {`
	`206`	`+ setData(*messageProto, std::move(codec->Decompress(dataChunk.GetData())));`
	`207`	`+ } catch (const std::exception& e) {`
	`208`	`+ setData(*messageProto, ">>> Message decompression failed <<<");`
	`209`	`+ }`
`206`	`210`	`} else {`
`207`	`211`	`setData(messageProto, std::move(dataChunk.MutableData()));`
`208`	`212`	`}`