Hi, Im trying out the high level consumer using the ConsumerConnector API . I have a topic with 100 partitions . What does it mean if I create messagestreams with
consumerConnector.createMessageStreams(Predef.Map(topic -> partitions), decoder) where partitions < 100 (say 50). does the consumer read messages only from 50 of the 100 partitions ? Sam William sa...@stumbleupon.com