thanks, I just noticed the consumerconnector.createMessageStream Api, it
has 2 versions
public Map>>
createMessageStreams(Map topicCountMap, Decoder
keyDecoder, Decoder valueDecoder);
/**
* Create a list of message streams of type T for each topic, using the
default decoder.
*/
p
There has to be an implicit contract between the producer and
consumer. The K, V pairs don't _need_ to match but generally _should_.
If producer sends with the consumer may receive as
long as it knows how to convert those raw bytes to . In the
example if CK == byte[] and CV == byte[] it is effect
in the example
https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+Producer+Example
we use a String,String for
in the same set of example
https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example
on the consumer side we use byte[], byte[] for K,V
ConsumerIterator it =
