[
https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198121#comment-17198121
]
limbo commented on FLINK-19285:
-------------------------------
I tracked the code and find that
[https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java#L933]
the default AT_LEASTE_ONCE not call the partitioner open function, so the
parallelInstanceId set default 0
> 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
> Priority: Critical
>
> 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)
