Details
-
Bug
-
Status: Closed
-
Critical
-
Resolution: Duplicate
-
1.11.0
-
None
-
None
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
Attachments
Issue Links
- duplicates
-
FLINK-19133 User provided kafka partitioners are not initialized correctly
- Closed