You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/07 07:18:00 UTC
[jira] [Created] (FLINK-17026) Introduce a new Kafka connector with
new property keys
Jark Wu created FLINK-17026:
-------------------------------
Summary: Introduce a new Kafka connector with new property keys
Key: FLINK-17026
URL: https://issues.apache.org/jira/browse/FLINK-17026
Project: Flink
Issue Type: Sub-task
Components: Connectors / Kafka, Table SQL / Ecosystem
Reporter: Jark Wu
Fix For: 1.11.0
This new Kafka connector should use new interfaces proposed by FLIP-95, e.g. DynamicTableSource, DynamicTableSink, and Factory.
The new proposed keys :
||Old key||New key||Note||
|connector.type|connector| |
|connector.version|N/A|merged into 'connector' key|
|connector.topic|topic| |
|connector.properties.zookeeper.connect|properties.zookeeper.connect| |
|connector.properties.bootstrap.servers|properties.bootstrap.servers| |
|connector.properties.group.id|properties.group.id| |
|connector.startup-mode|scan.startup.mode| |
|connector.specific-offsets|scan.startup.specific-offsets| |
|connector.startup-timestamp-millis|scan.startup.timestamp-millis| |
|connector.sink-partitioner|sink.partitioner|"fixed", or "round-robin", or a class name "org.mycompany.MyPartitioner"|
|connector.sink-partitioner-class|N/A|merged into 'sink.partitioner', not needed anymore|
|format.type|format| |
--
This message was sent by Atlassian Jira
(v8.3.4#803005)