Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> SimpleConsumer cannot read KeyedMessage<byte[], byte[]>.


Copy link to this message
-
Re: SimpleConsumer cannot read KeyedMessage<byte[], byte[]>.
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 <[EMAIL PROTECTED]> 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.
>

 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB