[
https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982277#comment-15982277
]
ASF GitHub Bot commented on FLINK-6288:
---------------------------------------
GitHub user fanyon opened a pull request:
https://github.com/apache/flink/pull/3766
[FLINK-6288] fix FlinkKafkaProducer's custom Partitioner is always invoked
with number of partitions of default topic
1. add extra api addTopicPartitioner, user can use it to add special topic
and partitioner
2. add topicPartitionerMap in FlinkKafkaProducerBase to store the topic and
partitioner
3. add PartitionerInfo to manage the topic and partitioner info
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/fanyon/flink FLINK-6288
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3766.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3766
----
commit a525fe605c25ce2e3c8c30cbc7c60542243c0a18
Author: mengji.fy <[email protected]>
Date: 2017-04-24T06:16:48Z
[FLINK-6288] fix target topic uses partitioner of default topic
commit 071e06c00e8a2346d4ebcede8784f1ada5457da2
Author: mengji.fy <[email protected]>
Date: 2017-04-25T02:03:08Z
add serialVersionUID field in PartitionerInfo
----
> 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)
