Re: ("offsets.storage","kafka") not working with Consumer API

2015-10-18 Thread Kiran Singh
Hi Any update? On Fri, Oct 16, 2015 at 12:33 PM, Kiran Singh wrote: > Hi Stevo > > I have 3 broker in my kafka cluster. > > On Fri, Oct 16, 2015 at 12:21 PM, Stevo Slavić wrote: > >> Hello Kiran, >> >> Check how many brokers you have in the cluster. Consumer offsets topic >> requires by defaul

Re: ("offsets.storage","kafka") not working with Consumer API

2015-10-16 Thread Kiran Singh
Hi Stevo I have 3 broker in my kafka cluster. On Fri, Oct 16, 2015 at 12:21 PM, Stevo Slavić wrote: > Hello Kiran, > > Check how many brokers you have in the cluster. Consumer offsets topic > requires by default at least 3. In dev environment you could lower > replication factor for that topic

Re: ("offsets.storage","kafka") not working with Consumer API

2015-10-15 Thread Stevo Slavić
Hello Kiran, Check how many brokers you have in the cluster. Consumer offsets topic requires by default at least 3. In dev environment you could lower replication factor for that topic (see broker config options). Kind regards, Stevo Slavic. On Fri, Oct 16, 2015, 07:31 Kiran Singh wrote: > Hel

("offsets.storage","kafka") not working with Consumer API

2015-10-15 Thread Kiran Singh
Hello I am trying to use ConsumerConnector API. But if i used ("offsets.storage","kafka") property "createJavaConsumerConnector" function will hang. And I removed this, API work fine. I am using kafka_2.10-0.8.2.2.jar Is there any issue or I am missing any thing. Thanks Kiran Singh