2424import lombok .extern .slf4j .Slf4j ;
2525import net .jpountz .lz4 .LZ4Compressor ;
2626import net .jpountz .lz4 .LZ4Factory ;
27- import net .jpountz .lz4 .LZ4FastDecompressor ;
27+ import net .jpountz .lz4 .LZ4SafeDecompressor ;
2828import org .apache .pulsar .common .allocator .PulsarByteBufAllocator ;
2929
3030/**
@@ -44,7 +44,7 @@ public class CompressionCodecLZ4JNI implements CompressionCodec {
4444
4545 private static final LZ4Factory lz4Factory = LZ4Factory .fastestInstance ();
4646 private static final LZ4Compressor compressor = lz4Factory .fastCompressor ();
47- private static final LZ4FastDecompressor decompressor = lz4Factory .fastDecompressor ();
47+ private static final LZ4SafeDecompressor decompressor = lz4Factory .safeDecompressor ();
4848
4949 @ Override
5050 public ByteBuf encode (ByteBuf source ) {
@@ -67,10 +67,10 @@ public ByteBuf decode(ByteBuf encoded, int uncompressedLength) throws IOExceptio
6767 ByteBuffer uncompressedNio = uncompressed .nioBuffer (0 , uncompressedLength );
6868
6969 ByteBuffer encodedNio = encoded .nioBuffer (encoded .readerIndex (), encoded .readableBytes ());
70- decompressor .decompress (encodedNio , encodedNio .position (), uncompressedNio , uncompressedNio . position (),
71- uncompressedNio .remaining ());
70+ decompressor .decompress (encodedNio , encodedNio .position (), encodedNio . remaining (),
71+ uncompressedNio , uncompressedNio . position (), uncompressedNio .remaining ());
7272
7373 uncompressed .writerIndex (uncompressedLength );
7474 return uncompressed ;
7575 }
76- }
76+ }
0 commit comments