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

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 (see broker config options).
>
> Kind regards,
> Stevo Slavic.
>
> On Fri, Oct 16, 2015, 07:31 Kiran Singh  wrote:
>
> > 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
> >
>

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:

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

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