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 >