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

Reply via email to