Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> as i understand rebalance happens on client side


Copy link to this message
-
Re: as i understand rebalance happens on client side
I think you want locking to prevent two processes from consuming the same
partition. You can just use the high level consumer to get this group
management functionality. It ensures that a partition is only consumed by
one high level consumer at any given time. Is there any particular reason
why you want to use SimpleConsumer instead?

Thanks,
Neha
On Tue, Oct 1, 2013 at 8:42 AM, Kane Kane <[EMAIL PROTECTED]> wrote:

> So essentially you can't do "queue" pattern, unless you somehow implement
> locking on the client?
>
>
> On Tue, Oct 1, 2013 at 8:35 AM, Guozhang Wang <[EMAIL PROTECTED]> wrote:
>
> > SimpleConsumer do not have any concept of group management, only the
> > high-level consumers have. So multiple simple consumers can independently
> > consume from the same partition(s).
> >
> > Guozhang
> >
> >
> > On Tue, Oct 1, 2013 at 8:11 AM, Kane Kane <[EMAIL PROTECTED]> wrote:
> >
> > > Yeah, I noticed that, i'm curious how balancing happens if
> SimpleConsumer
> > > is used. I.e. i can provide a partition to read from if i use
> > > SimpleConsumer, but what if someone else already attached to that
> > > partition, what would happen? Also what would happen if one
> > SimpleConsumer
> > > attached to all partitions? Noone would be able to join?
> > >
> > >
> > > On Tue, Oct 1, 2013 at 6:33 AM, Neha Narkhede <[EMAIL PROTECTED]
> > > >wrote:
> > >
> > > > There are 2 types of consumer clients in Kafka -
> > > ZookeeperConsumerConnector
> > > > and SimpleConsumer. Only the former has the re balancing logic.
> > > >
> > > > Thanks,
> > > > Neha
> > > > On Oct 1, 2013 6:30 AM, "Kane Kane" <[EMAIL PROTECTED]> wrote:
> > > >
> > > > > But it looks like some clients don't implement it?
> > > > >
> > > >
> > >
> >
> >
> >
> > --
> > -- Guozhang
> >
>