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 wrote:
> Hi,
> The Flink kafka producer uses fixed partitioner by default an
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
