Tzu-Li (Gordon) Tai created FLINK-8181: ------------------------------------------
Summary: Kafka producer's FlinkFixedPartitioner returns different partitions when a target topic is rescaled Key: FLINK-8181 URL: https://issues.apache.org/jira/browse/FLINK-8181 Project: Flink Issue Type: Bug Components: Kafka Connector Affects Versions: 1.4.0, 1.5.0 Reporter: Tzu-Li (Gordon) Tai Assignee: Tzu-Li (Gordon) Tai Priority: Blocker Fix For: 1.4.0, 1.5.0 On fixing FLINK-6288 and migrating the original {{FlinkFixedPartitioner}} to the new partitioning API (commit 9ed9b68397b51bfd2b0f6e532212a82f771641bd), the {{FlinkFixedPartitioner}} no longer returns identical target partitions once a target topic is rescaled. The {{FlinkFixedPartitionerTest}} should also be strengthened to cover the target topic rescaling case. -- This message was sent by Atlassian JIRA (v6.4.14#64029)