You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/05/07 12:38:00 UTC
[jira] [Updated] (FLINK-7913) Add support for Kafka default
partitioner
[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aljoscha Krettek updated FLINK-7913:
------------------------------------
Fix Version/s: (was: 1.6.0)
> Add support for Kafka default partitioner
> -----------------------------------------
>
> Key: FLINK-7913
> URL: https://issues.apache.org/jira/browse/FLINK-7913
> Project: Flink
> Issue Type: Improvement
> Components: Kafka Connector
> Affects Versions: 1.4.0
> Reporter: Konstantin Lalafaryan
> Assignee: Konstantin Lalafaryan
> Priority: Major
>
> 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
(v7.6.3#76005)