kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sam William <sa...@stumbleupon.com>
Subject High level consumer Question
Date Tue, 12 Jun 2012 02:11:26 GMT
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
sampd@stumbleupon.com




Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message