You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "limbo (Jira)" <ji...@apache.org> on 2020/09/18 05:33:00 UTC

[jira] [Created] (FLINK-19285) Kafka sql connector fixed partitioner not work

limbo created FLINK-19285:
-----------------------------

             Summary: 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.2
         Environment: 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
            Reporter: limbo


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)