flink-cdc

flink-cdc copied to clipboard

**Is your feature request related to a problem? Please describe.** Unable get `transaction.id` from MySQL CDC while the underlying Debezium provides it **Describe the solution you'd like** Something like below...

tao-xiao-sn

[common] Add Flink 1.15 support.

3

Bumped Flink version to 1.15.1. Added Maven profile for Flink 1.14 compatibility. Relates to #1363

tigrulya-exe

is there some flag that help me get the primary key in output

2

I use flink cdc in copy the mysql data from one to another, what I want is tell me which column is the primary key in the output. So I...

foobarrer

Resolve project compilation ⚠️ trivial code submission

zhilinli123

alter cdc version

2

error url

Toms1999

**Is your feature request related to a problem? Please describe.** I make a mysql sink function for write the data from kafka to mysql ***When use the dataStream API ,...

foobarrer

使用CDC实时同步数据需要一直连接数据库吗

9

发现CDC是直接连接数据库的，如果使用CDC进行实时的数据同步，需要一直连接数据库吗？ 如果是的话，那要是多个job进行实时的数据同步，那数据库就会一直连接多个job，数据库压力不会太大吗？

Blank-creator397

请问flink-cdc支持MongoDB 6.0吗？

1

请问flink-cdc支持MongoDB 6.0吗？

csj-9-9

ddl support

7

什么时候支持ddl？ 上游数据源schema修改 flink-cdc可以自动修复下游动态表schema

sunfu103

flink-connector-oracle-cdc

2

flinkcdc 监听 Oracle： flinkcdc 版本：2.2.1 Oracle 版本：Oracle Database 19c  使用时候报错： ORA-12505, TNS:listener does not currently know of SID given in connect descriptor 

xpdgit123