flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Metzger <rmetz...@apache.org>
Subject Re: Kafka producer connector
Date Mon, 08 Aug 2016 19:31:03 GMT
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.reddy@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
>

Mime
View raw message