Konstantin Lalafaryan created FLINK-7913:
--------------------------------------------
Summary: Add support for Kafka default partitioner
Key: FLINK-7913
URL: https://issues.apache.org/jira/browse/FLINK-7913
Project: Flink
Issue Type: Improvement
Reporter: Konstantin Lalafaryan
Assignee: Konstantin Lalafaryan
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)
