[
https://issues.apache.org/jira/browse/FLINK-17026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17026:
-----------------------------------
Labels: pull-request-available (was: )
> 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
> Assignee: Danny Chen
> Priority: Major
> Labels: pull-request-available
> 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)
