For 0.8, you can find the example in the following wiki. https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example
Thanks, Jun On Tue, Jun 4, 2013 at 12:56 AM, Vadim Keylis <vkeylis2...@gmail.com> 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, > Vadim >
