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 >
