[jira] [Created] (FLINK-17026) Introduce a new Kafka connector with new property keys

[Shang Yuanchun (Jira)]

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)