Hi Janardhan, the fixed partitioner is the only one shipped with Flink. However, it should be fairly simple to implement one that uses the key to determine the partition.
On Mon, Aug 8, 2016 at 7:16 PM, Janardhan Reddy <janardhan.re...@olacabs.com > wrote: > Hi, > The Flink kafka producer uses fixed partitioner by default and all our > events are ending up in 1-2 partitions. Is there any inbuilt partitioner > which distributes keys such that same key maps to same partition. > > Thanks >
