Code Example for createMessageStreams

[Vadim Keylis]

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