You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Timothy Chen <tn...@gmail.com> on 2013/05/31 22:42:15 UTC

Custom partitioner

Hi,

I'm trying to add my own custom partitioner and saw the example in the 0.8
producer example in the wiki.

However, when I set a broker list and set the custom partitioner class name
I did in the client, I see this error:


Partitioner cannot be used when broker list is set



Does this means a custom partitioner is only available when I use Zookeeper
to connect to Kafka?

Thanks,



Tim

Re: Custom partitioner

Posted by Jun Rao <ju...@gmail.com>.
Hmm, I am not aware that we have an 0.8 C# client. Which one are you using?

Thanks,

Jun


On Fri, May 31, 2013 at 9:44 PM, Tim Chen (343) <ti...@microsoft.com> wrote:

> I am using 0.8 Kafka with c# client.
>
> Tim
>
> Sent from my iPhone
>
> On May 31, 2013, at 8:50 PM, "Jun Rao" <ju...@gmail.com> wrote:
>
> > Are you using the 0.8 branch code? That error is for the 0.7 release.
> >
> > Thanks,
> >
> > Jun
> >
> >
> > On Fri, May 31, 2013 at 1:42 PM, Timothy Chen <tn...@gmail.com> wrote:
> >
> >> Hi,
> >>
> >> I'm trying to add my own custom partitioner and saw the example in the
> 0.8
> >> producer example in the wiki.
> >>
> >> However, when I set a broker list and set the custom partitioner class
> name
> >> I did in the client, I see this error:
> >>
> >>
> >> Partitioner cannot be used when broker list is set
> >>
> >>
> >>
> >> Does this means a custom partitioner is only available when I use
> Zookeeper
> >> to connect to Kafka?
> >>
> >> Thanks,
> >>
> >>
> >>
> >> Tim
> >>
>
>

Re: Custom partitioner

Posted by "Tim Chen (343)" <ti...@microsoft.com>.
I am using 0.8 Kafka with c# client.

Tim

Sent from my iPhone

On May 31, 2013, at 8:50 PM, "Jun Rao" <ju...@gmail.com> wrote:

> Are you using the 0.8 branch code? That error is for the 0.7 release.
> 
> Thanks,
> 
> Jun
> 
> 
> On Fri, May 31, 2013 at 1:42 PM, Timothy Chen <tn...@gmail.com> wrote:
> 
>> Hi,
>> 
>> I'm trying to add my own custom partitioner and saw the example in the 0.8
>> producer example in the wiki.
>> 
>> However, when I set a broker list and set the custom partitioner class name
>> I did in the client, I see this error:
>> 
>> 
>> Partitioner cannot be used when broker list is set
>> 
>> 
>> 
>> Does this means a custom partitioner is only available when I use Zookeeper
>> to connect to Kafka?
>> 
>> Thanks,
>> 
>> 
>> 
>> Tim
>>

Re: Custom partitioner

Posted by Jun Rao <ju...@gmail.com>.
Are you using the 0.8 branch code? That error is for the 0.7 release.

Thanks,

Jun


On Fri, May 31, 2013 at 1:42 PM, Timothy Chen <tn...@gmail.com> wrote:

> Hi,
>
> I'm trying to add my own custom partitioner and saw the example in the 0.8
> producer example in the wiki.
>
> However, when I set a broker list and set the custom partitioner class name
> I did in the client, I see this error:
>
>
> Partitioner cannot be used when broker list is set
>
>
>
> Does this means a custom partitioner is only available when I use Zookeeper
> to connect to Kafka?
>
> Thanks,
>
>
>
> Tim
>