Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-6288

FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.3.0, 1.4.0
    • Component/s: Kafka Connector
    • Labels:
      None

      Description

      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.

        Attachments

          Activity

            People

            • Assignee:
              zjureel Fang Yong
              Reporter:
              tzulitai Tzu-Li (Gordon) Tai
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: