For 0.8, you can find the example in the following wiki.
On Tue, Jun 4, 2013 at 12:56 AM, Vadim Keylis <[EMAIL PROTECTED]> wrote:
> Good evening. Would it be possible to get sample code where the api bellow
> is used in the consumer with sample of Decoder.
> public <K,V> Map<String, List<KafkaStream<K,V>>>
> createMessageStreams(Map<String, Integer> topicCountMap, Decoder<K>
> keyDecoder, Decoder<V> valueDecoder);
> Thanks so much in advance,