SimpleConsumer cannot read KeyedMessage.

[Lu Xuechao]

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.