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



Reply via email to