[ https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241503#comment-17241503 ]
Lyr commented on FLINK-19285: ----------------------------- okĀ i understand thank you > Kafka sql connector fixed partitioner not work > ---------------------------------------------- > > Key: FLINK-19285 > URL: https://issues.apache.org/jira/browse/FLINK-19285 > Project: Flink > Issue Type: Bug > Components: Connectors / Kafka > Affects Versions: 1.11.0 > Reporter: limbo > Priority: Critical > > {code:sql} > 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 > {code} > Hi, when I use sql kafka connector sink and set 'sink.partitioner'='fixed', > the partitioner not work, it only produce to the 0 partition -- This message was sent by Atlassian Jira (v8.3.4#803005)