It's a field of MessageAndMetadata actually but there won't be difference from Scala's view.
On Thu, Nov 27, 2014 at 9:57 AM, Palur Sandeep <psand...@hawk.iit.edu> wrote: > 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> >
