You are viewing a plain text version of this content. The canonical link for it is here.
Posted to community@flink.apache.org by neeraj pandey <ni...@gmail.com> on 2022/08/16 09:42:53 UTC
Retrieve the 'op' values as part of jdbc-cdc connector
Hello team,
I am trying to leverage the Apache Flink CDC connector for the databases.
While using this mysql-cdc connector i am trying to create table in Flink
using below command
-- creates a mysql cdc table sourceCREATE TABLE mysql_binlog (
id INT NOT NULL,
name STRING,
description STRING,
weight DECIMAL(10,3)
) WITH (
'connector' = 'mysql-cdc',
'hostname' = 'localhost',
'port' = '3306',
'username' = 'flinkuser',
'password' = 'flinkpw',
'database-name' = 'inventory',
'table-name' = 'products'
);
Is there an option of getting the details of the op column which contains
details if data was inserted, updated or deleted using jdbc-cdc and Flink
SQL. I am using Flink 1.13.
Please let me know any reference if available
Thanks
Neeraj