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 > > >
