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)
