Do you see the same issue if you send snappy data using the console producer instead of librdkafka?
On Wed, Feb 26, 2014 at 5:58 PM, Dan Hoffman <[email protected]> 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. >
