On Mon, Aug 18, 2014 at 7:27 PM, Josh J <joshjd...@gmail.com> wrote: > > You can see an example of using the SimpleConsumer here > < > > https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example > > > > Any suggestions on where in the code to modify the high level producer to > support reading from specific partitions ? > > High level producer? I'm assuming you meant to write the high level consumer, in which case it isn't possible. The link above, which has an example for reading messages off a specific partition, is for the Simple consumer, which ironically, is more complex than the high level consumer.
In short, if you have a usecase where you want to read from a specific partition, you will need to implement a simple consumer. -- Sharninder Josh > . > > On Thu, Aug 14, 2014 at 4:27 PM, Neha Narkhede <neha.narkh...@gmail.com> > wrote: > > > 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 > > > > > > > > > >
