Re: Decompressing RMQ streaming messages

2022-07-24 Thread Francis Conroy
Hi Venkat, I guess you're using another compression algorithm which isn't zlib, you'll have to adapt the code to work with your algorithm of choice. Kind regards, Francis On Fri, 22 Jul 2022 at 17:27, Ramana wrote: > Hi Francis - Thanks for the snippet. I tried using the same, however I get >

Re: Decompressing RMQ streaming messages

2022-07-22 Thread Ramana
Hi Francis - Thanks for the snippet. I tried using the same, however I get an error. Following is the error - java.util.zip.DataFormatException: incorrect header check. I see multiple errors, i beleive for every message i am seeing this stack trace? Any idea as to what could be causing this? T

Re: Decompressing RMQ streaming messages

2022-07-21 Thread Francis Conroy
Hi Venkat, there's nothing that I know of, but I've written a zlib decompressor for our payloads which was pretty straightforward. public class ZlibDeserializationSchema extends AbstractDeserializationSchema { @Override public byte[] deserialize(byte[] message) throws IOException {