[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Lalafaryan updated FLINK-7913:
-----------------------------------------
Description:
Currently in the Apache Flink it is available only *FlinkKafkaPartitioner* and
just one implementation *FlinkFixedPartitioner*.
I think it will be really good to allow to use the Kafka's default partitioner.
Currently the only way that you can do it to implement the
*FlinkKafkaPartitioner* and fork the source from the kafka.
Thanks.
was:
Currently in the Apache Flink it is available only `FlinkKafkaPartitioner` and
just one implementation `FlinkFixedPartitioner`.
I think it will be really good to allow to use the Kafka's default partitioner.
Currently the only way that you can do it to implement the
`FlinkKafkaPartitioner` and fork the source from the kafka.
Thanks.
> 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*.
> I think it will be really good to allow to use the Kafka's default
> partitioner. Currently the only way that you can do it to implement the
> *FlinkKafkaPartitioner* and fork the source from the kafka.
> Thanks.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
