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)