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