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
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
