Skip to content

Commit 802aa69

Browse files
authored
Improve message decompress error (#1342)
* Improve message decompress error * Fix lint
1 parent 6cb2867 commit 802aa69

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

pulsar/consumer_partition.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2147,7 +2147,12 @@ func (pc *partitionConsumer) Decompress(msgMeta *pb.MessageMetadata, payload int
21472147

21482148
uncompressed, err := provider.Decompress(nil, payload.ReadableSlice(), int(msgMeta.GetUncompressedSize()))
21492149
if err != nil {
2150-
return nil, err
2150+
return nil, fmt.Errorf("failed to decompress message: %w, compression type: %d, payload size: %d, "+
2151+
"uncompressed size: %d",
2152+
err,
2153+
msgMeta.GetCompression(),
2154+
len(payload.ReadableSlice()),
2155+
msgMeta.GetUncompressedSize())
21512156
}
21522157

21532158
return internal.NewBufferWrapper(uncompressed), nil

0 commit comments

Comments
 (0)