Publisher (using librdkafka C api) has sent both gzip and snappy compressed messages. I find that the java Simple Consumer ( https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example#) is unable to read the snappy ones, while the High Level one is. Is this expected? Is there something you have to do in order to handle the snappy messages? There is no error messages provided, it simply acts as if there are no further messages.
- Problems consuming snappy compressed messages via SimpleCons... Dan Hoffman
- Re: Problems consuming snappy compressed messages via S... Neha Narkhede
- Re: Problems consuming snappy compressed messages v... Dan Hoffman
- Re: Problems consuming snappy compressed messag... Neha Narkhede
- Re: Problems consuming snappy compressed me... Dan Hoffman
- Re: Problems consuming snappy compress... Neha Narkhede