You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by sunil kalva <ka...@gmail.com> on 2015/02/19 13:35:01 UTC
Custom partitioner in kafka-0.8.2.0
Hi
I could not find a way to customize "Partitioner" class in new KafaProducer
class, is it intentional ?
tx
SunilKalva
Re: Custom partitioner in kafka-0.8.2.0
Posted by sunil kalva <ka...@gmail.com>.
thanks mani for quick response, sorry some how i missed this javadoc :)
t
SunilKalva
On Thu, Feb 19, 2015 at 6:14 PM, Manikumar Reddy <ku...@nmsworks.co.in>
wrote:
> Hi,
>
> In new producer, we can specify the partition number as part of
> ProducerRecord.
>
> From javadocs :
> *"If a valid partition number is specified that partition will be used when
> sending the record. If no partition is specified but a key is present a
> partition will be chosen using a hash of the key. If neither key nor
> partition is present a partition will be assigned in a round-robin fashion.
> "*
>
>
> http://kafka.apache.org/082/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html
>
>
> ManiKumar
>
> On Thu, Feb 19, 2015 at 6:05 PM, sunil kalva <ka...@gmail.com>
> wrote:
>
> > Hi
> > I could not find a way to customize "Partitioner" class in new
> KafaProducer
> > class, is it intentional ?
> >
> > tx
> > SunilKalva
> >
>
Re: Custom partitioner in kafka-0.8.2.0
Posted by Manikumar Reddy <ku...@nmsworks.co.in>.
Hi,
In new producer, we can specify the partition number as part of
ProducerRecord.
>From javadocs :
*"If a valid partition number is specified that partition will be used when
sending the record. If no partition is specified but a key is present a
partition will be chosen using a hash of the key. If neither key nor
partition is present a partition will be assigned in a round-robin fashion.
"*
http://kafka.apache.org/082/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html
ManiKumar
On Thu, Feb 19, 2015 at 6:05 PM, sunil kalva <ka...@gmail.com> wrote:
> Hi
> I could not find a way to customize "Partitioner" class in new KafaProducer
> class, is it intentional ?
>
> tx
> SunilKalva
>
Re: Custom partitioner in kafka-0.8.2.0
Posted by sunil kalva <ka...@gmail.com>.
> Hi
> I could not find a way to customize "Partitioner" class in new
> KafaProducer class, is it intentional ?
>
> tx
>
SunilKalva
>