Thank you. but I dont see that method. I dont know whats wrong On Wed, Nov 26, 2014 at 6:31 PM, Jun Rao <jun...@gmail.com> wrote:
> Yes, the consumer iterator returns MessageAndMetadata which contains a > method partition(). > > Thanks, > > Jun > > On Wed, Nov 26, 2014 at 10:40 AM, Palur Sandeep <psand...@hawk.iit.edu> > wrote: > > > Hi all, > > > > I am using kafka version 0.8.1.1. In the consumer side, can I find out > the > > partition id of each message I am consuming using high level consumer > API? > > > > Thanks, > > Sandeep > > > > -- > > Regards, > > Sandeep Palur > > Data-Intensive Distributed Systems Laboratory, CS/IIT > > Department of Computer Science, Illinois Institute of Technology (IIT) > > Phone : 312-647-9833 > > Email : psand...@hawk.iit.edu <sraja...@hawk.iit.edu> > > > -- Regards, Sandeep Palur Data-Intensive Distributed Systems Laboratory, CS/IIT Department of Computer Science, Illinois Institute of Technology (IIT) Phone : 312-647-9833 Email : psand...@hawk.iit.edu <sraja...@hawk.iit.edu>