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 <[email protected]> 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 <[email protected]> > wrote: > > > Hi > > I could not find a way to customize "Partitioner" class in new > KafaProducer > > class, is it intentional ? > > > > tx > > SunilKalva > > >
