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