Yes, the consumer iterator returns MessageAndMetadata which contains a method partition().
Thanks, Jun On Wed, Nov 26, 2014 at 10:40 AM, Palur Sandeep <[email protected]> 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 : [email protected] <[email protected]> >
