[
https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978308#comment-15978308
]
Tzu-Li (Gordon) Tai commented on FLINK-6288:
--------------------------------------------
Sure, please go ahead. And thanks for picking this up!
By the way, just to make sure you're up to sync with the whole picture of this
JIRA, here's the mailing list thread where the discussion of this issue took
place:
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Possible-bug-in-Kafka-producer-partitioning-logic-td16972.html.
cc [~rmetzger], in case you would like to chime in any early discussions here,
as I think this would require a change in our Kafka sink's custom partitioner
API (see ML thread for details).
> 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
>
> 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)
