在flinksql format debezium-json中解析失败,格式不同,要怎么办?
{
'version': '1.0',
'connector': 'mysql',
'name': 'inventory-connector',
'config': {
'hostname': 'localhost',
'port': '3306',
'username': 'root',
'password': 'password',
'database': 'inventory',
'table.whitelist': 'products',
'timestamp.format.standard': 'ISO-8601',
'include.schema.changes': 'false',
'deserialization.format': 'debezium-json'
}
}
赞0
踩0