Thanks !

On Tue, Feb 24, 2015 at 8:23 PM, Gwen Shapira <gshap...@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 <teddyyyy...@gmail.com> wrote:
>
> > I looked at the example camus.properties, it does not specify this. how
> > could we set the groupId ?
> >
> > thanks
> > Yang
> >
>

Reply via email to