MOBIN created FLINK-36958:
-----------------------------
Summary: 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
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)
