kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Manu Zhang <owenzhang1...@gmail.com>
Subject Re: Partition id of consumed message?
Date Fri, 28 Nov 2014 01:25:45 GMT
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 <psandeep@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 <junrao@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 <psandeep@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 <srajasur@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 <srajasur@hawk.iit.edu>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message