in the example
https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+Producer+Example

we use a String,String for <K,V>

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<byte[], byte[]> it = m_stream.iterator();



we tested in our own code that the above producer-consumer pair does work.


so the K,V types on the 2 sides do NOT need to match? if we argue that
"everything has to come down to byte[], then maybe we don't need the
generics types on the consumer side? in other words, how do we determine
the K,V types on consumer side?

thanks
Yang

Reply via email to