[
https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16015499#comment-16015499
]
ASF GitHub Bot commented on FLINK-6288:
---------------------------------------
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3901
@zjureel I'll be merging this only for 1.4-SNAPSHOT. The main reason is
that there is a lot of deprecation / API change with this, and I'll like to
ship it along with other API changes we had in mind to make sure they go nicely
together.
This is of highest priority for at the moment, and I'll make sure it gets
into 1.4-SNAPSHOT as soon as possible.
@gyfora I understand that this was sort of a blocker for you, but I would
prefer to not rush the changes into the release. I hope you can understand.
> FlinkKafkaProducer's custom Partitioner is always invoked with number of
> partitions of default topic
> ----------------------------------------------------------------------------------------------------
>
> Key: FLINK-6288
> URL: https://issues.apache.org/jira/browse/FLINK-6288
> Project: Flink
> Issue Type: Improvement
> Components: Kafka Connector
> Reporter: Tzu-Li (Gordon) Tai
> Assignee: Fang Yong
>
> The {{FlinkKafkaProducerBase}} supports routing records to topics besides the
> default topic, but the custom {{Partitioner}} interface does not follow this
> semantic.
> The partitioner is always invoked the {{partition}} method with the number of
> partitions in the default topic, and not the number of partitions of the
> current {{targetTopic}}.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
