It seems the reason is I enabled gzip compression. what the code would like to consume compressed messages?
thanks. On Thu, Oct 31, 2013 at 11:26 AM, Lu Xuechao <lux...@gmail.com> wrote: > Hi, > > I am following the > https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example > > When I send KeyedMessage<String, String> with StringEncoder, I can get the > messages sent: > > for (MessageAndOffset messageAndOffset : fetchResponse.messageSet(m_topic, > m_partition)) { > //handle messages > } > > But when I send KeyedMessage<byte[], byte[]> with DefaultEncoder, I cannot > get the messages: > > Iterator<MessageAndOffset> itr = fetchResponse.messageSet(m_topic, > m_partition).iterator(); > itr.hasNext() is FALSE. > > the test code is the same, what is causing this? What change needs to be > made? > > thanks. >
