You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Yang <te...@gmail.com> on 2015/02/24 21:26:34 UTC

what groupID does camus use?

I looked at the example camus.properties, it does not specify this. how
could we set the groupId ?

thanks
Yang

Re: what groupID does camus use?

Posted by Yang <te...@gmail.com>.

Thanks !

On Tue, Feb 24, 2015 at 8:23 PM, Gwen Shapira <gs...@cloudera.com> wrote:

> Camus uses the simple consumer, which doesn't have the concept of "consumer
> group" in the API (i.e. Camus is responsible for allocating threads to
> partitions on its own).
>
> The client-id is hard coded and is "hadoop-etl" in some places (when it
> initializes the offsets) and "camus" in other places.
> The name "camus" is defined in camus.properties in "kafka.client.name", so
> you can override it.
>
> Gwen
>
> On Tue, Feb 24, 2015 at 12:26 PM, Yang <te...@gmail.com> wrote:
>
> > I looked at the example camus.properties, it does not specify this. how
> > could we set the groupId ?
> >
> > thanks
> > Yang
> >
>

Re: what groupID does camus use?

Posted by Gwen Shapira <gs...@cloudera.com>.

Camus uses the simple consumer, which doesn't have the concept of "consumer
group" in the API (i.e. Camus is responsible for allocating threads to
partitions on its own).

The client-id is hard coded and is "hadoop-etl" in some places (when it
initializes the offsets) and "camus" in other places.
The name "camus" is defined in camus.properties in "kafka.client.name", so
you can override it.

Gwen

On Tue, Feb 24, 2015 at 12:26 PM, Yang <te...@gmail.com> wrote:

> I looked at the example camus.properties, it does not specify this. how
> could we set the groupId ?
>
> thanks
> Yang
>