Hi - We have a requirement to read the compressed messages emitting out of RabbitMQ and to have them processed using PyFlink. However, I am not finding any out of the box functionality in PyFlink which can help decompress the messages.
Could anybody help me with an example of how to go about this? Appreciate any help here. Thanks ~Venkat
