You can see an example of using the SimpleConsumer here <https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example> .
On Thu, Aug 14, 2014 at 3:23 AM, Sharninder <sharnin...@gmail.com> wrote: > Implement the low level "Simple Consumer". > > -- > Sharninder > > > > On Thu, Aug 14, 2014 at 2:16 PM, Josh J <joshjd...@gmail.com> wrote: > > > Hi, > > > > Suppose I have N partitions. I would like to have X different consumer > > threads ( X < N) read from a specified set of partitions. How can I > achieve > > this? > > > > Thanks, > > > > Josh > > >
