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
