[
https://issues.apache.org/jira/browse/FLINK-36958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36958:
----------------------------------
Assignee: MOBIN
> Support pipeline-connector-kafka to reuse csv, canal-json and debezium-json
> Format Options
> ------------------------------------------------------------------------------------------
>
> Key: FLINK-36958
> URL: https://issues.apache.org/jira/browse/FLINK-36958
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.2.0
> Reporter: MOBIN
> Assignee: MOBIN
> Priority: Major
>
> When using Format Options in pipeline, such as
> debezium-json.encode.decimal-as-plain-number, an exception of Unsupported
> options will be thrown
> {code:java}
> source:
> type: mysql
> sink:
> type: kafka
> ....
> value.format: debezium-json
> debezium-json.encode.decimal-as-plain-number: true{code}
> {code:java}
> Exception in thread "main" org.apache.flink.table.api.ValidationException:
> Unsupported options found for 'kafka'.
> Unsupported options:
> debezium-json.encode.decimal-as-plain-number
> Supported options:
> sink.custom-header
> value.format
> sink.add-tableId-to-header-enabled
> key.format
> topic
> sink.delivery-guarantee
> partition.strategy
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
