Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> Code Example for createMessageStreams


Copy link to this message
-
Re: Code Example for createMessageStreams
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 <[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,
> Vadim
>