From 802aa691e77dfa24776ff0270ee3560450a8308e Mon Sep 17 00:00:00 2001
From: Zike Yang <zike@apache.org>
Date: Fri, 7 Mar 2025 11:46:42 +0800
Subject: [PATCH] Improve message decompress error (#1342)

* Improve message decompress error

* Fix lint
---
 pulsar/consumer_partition.go | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/pulsar/consumer_partition.go b/pulsar/consumer_partition.go
index 13fa9b4c4..aa922af23 100644
--- a/pulsar/consumer_partition.go
+++ b/pulsar/consumer_partition.go
@@ -2147,7 +2147,12 @@ func (pc *partitionConsumer) Decompress(msgMeta *pb.MessageMetadata, payload int
 
 	uncompressed, err := provider.Decompress(nil, payload.ReadableSlice(), int(msgMeta.GetUncompressedSize()))
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("failed to decompress message: %w, compression type: %d, payload size: %d, "+
+			"uncompressed size: %d",
+			err,
+			msgMeta.GetCompression(),
+			len(payload.ReadableSlice()),
+			msgMeta.GetUncompressedSize())
 	}
 
 	return internal.NewBufferWrapper(uncompressed), nil