Fix CompressMaxSize() for ZLib provider (#312)

apache · Jul 7, 2020 · 6a80299 · 6a80299
1 parent ee17df9
commit 6a80299
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pulsar/internal/compression/zlib.go b/pulsar/internal/compression/zlib.go
@@ -31,7 +31,9 @@ func NewZLibProvider() Provider {
 }
 
 func (zlibProvider) CompressMaxSize(originalSize int) int {
-	return int(float32(originalSize) * 1.10)
+	// Use formula from ZLib: https://github.com/madler/zlib/blob/cacf7f1d4e3d44d871b605da3b647f07d718623f/deflate.c#L659
+	return originalSize +
+		((originalSize + 7) >> 3) + ((originalSize + 63) >> 6) + 11
 }
 
 func (zlibProvider) Compress(dst, src []byte) []byte {