You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Palur Sandeep <ps...@hawk.iit.edu> on 2014/11/26 19:40:04 UTC
Partition id of consumed message?
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 : psandeep@hawk.iit.edu <sr...@hawk.iit.edu>
Re: Partition id of consumed message?
Posted by Manu Zhang <ow...@gmail.com>.
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 <ps...@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 <ju...@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 <ps...@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 : psandeep@hawk.iit.edu <sr...@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 : psandeep@hawk.iit.edu <sr...@hawk.iit.edu>
>
Re: Partition id of consumed message?
Posted by Palur Sandeep <ps...@hawk.iit.edu>.
Thank you. but I dont see that method. I dont know whats wrong
On Wed, Nov 26, 2014 at 6:31 PM, Jun Rao <ju...@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 <ps...@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 : psandeep@hawk.iit.edu <sr...@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 : psandeep@hawk.iit.edu <sr...@hawk.iit.edu>
Re: Partition id of consumed message?
Posted by Jun Rao <ju...@gmail.com>.
Yes, the consumer iterator returns MessageAndMetadata which contains a
method partition().
Thanks,
Jun
On Wed, Nov 26, 2014 at 10:40 AM, Palur Sandeep <ps...@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 : psandeep@hawk.iit.edu <sr...@hawk.iit.edu>
>