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/05/06 14:33:00 UTC
[jira] [Assigned] (FLINK-17026) Introduce a new Kafka connector
with new property keys
[ https://issues.apache.org/jira/browse/FLINK-17026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jark Wu reassigned FLINK-17026:
-------------------------------
Assignee: Danny Chen
> 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
> 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)