Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- private static LZ4Compressor COMPRESS = LZ4Factory.fastestInstance().highCompressor();
- String meMessageString = "My Message that I am sending to kafka";
- byte[] uncompressedBytes = jsonRequest.getBytes();
- long lz4compressedLength = COMPRESSOR.compress(uncompressedBytes).length;
Add Comment
Please, Sign In to add comment