[FLINK-19285] Kafka sql connector fixed partitioner not work

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Duplicate
• Affects Version/s: 1.11.0
• Component/s: Connectors / Kafka
• Assignee: Unassigned
• Reporter: limbo
• Created: 18/Sep/20 05:32
• Updated: 01/Dec/20 13:00
• Resolved: 18/Sep/20 06:48

Description

CREATE TABLE kafkaTable (
 col1 BIGINT

) WITH (
 'connector' = 'kafka',
 'topic' = 'test',
 'properties.bootstrap.servers' = 'localhost:9092',
 'format' = 'csv',
 'scan.startup.mode' = 'earliest-offset'
);

CREATE TABLE kafkaTable1 (
 col1 BIGINT
) WITH (
 'connector' = 'kafka',
 'topic' = 'test1',
 'properties.bootstrap.servers' = 'localhost:9092',
 'format' = 'csv',
 'sink.partitioner'='fixed'
);


insert into kafkaTable1 select col1 from kafkaTable

Hi, when I use sql kafka connector sink and set 'sink.partitioner'='fixed', the partitioner not work, it only produce to the 0 partition

Issue Links

• duplicates: FLINK-19133 User provided kafka partitioners are not initialized correctly