[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

["Aljoscha Krettek (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16218556#comment-16218556 ] 

Aljoscha Krettek commented on FLINK-7913:
-----------------------------------------

This issue aims at using vanilla Kafka partitioners with the {{FlinkKafkaProducers}}, right? If yes, I'm very much in favour of this.

> Add support for Kafka default partitioner
> -----------------------------------------
>
>                 Key: FLINK-7913
>                 URL: https://issues.apache.org/jira/browse/FLINK-7913
>             Project: Flink
>          Issue Type: Improvement
>    Affects Versions: 1.4.0
>            Reporter: Konstantin Lalafaryan
>            Assignee: Konstantin Lalafaryan
>             Fix For: 1.5.0
>
>
> Currently in the Apache Flink it is available only *FlinkKafkaPartitioner* and just one implementation *FlinkFixedPartitioner*. 
> In order to be able to use Kafka's default partitioner you have to create new implementation for *FlinkKafkaPartitioner* and fork the code from the Kafka. It will be really good to be able to define the partitioner without implementing the new class.
> Thanks.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)