Are you using a fetch size larger than the whole compressed unit? Thanks,
Jun On Wed, Feb 26, 2014 at 5:40 PM, Dan Hoffman <hoffman...@gmail.com> wrote: > 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. >
