Re: what groupID does camus use?

2015-02-27 Thread Yang 
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 tedd...@gmail.com wrote:

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

what groupID does camus use?

2015-02-24 Thread Yang 
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?

2015-02-24 Thread Gwen Shapira 
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 tedd...@gmail.com wrote:

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

 thanks
 Yang