[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286705#comment-16286705
]
Tzu-Li (Gordon) Tai commented on FLINK-7913:
--------------------------------------------
[~aljoscha] [~klalafaryan] Yes.
I think we should also do it now along with the constructors overhaul that is
coming up for the Kafka consumer / producer. That would give users a smoother /
predictable migration to the new behaviour.
Related JIRAs are FLINK-8191 (adding the round-robin partitioner) and
FLINK-5728 (which suggests new constructors for the producer).
> 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
> 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)
