flink cdc ????mysql binlog?????? streaming????????????????????reload????????????????????
hi all ??flink cdc??streaming mode??binlog??mysql??RELOADsqlcdc debezium.snap.shot.locking.mode = none streaming mode?
??????flink cdc ????mysql binlog?????? streaming????????????????????reload????????????????????
datastreaming API??debeziumdebezium?? public static Properties debeziumProperties(){ Properties properties = new Properties(); properties.setProperty(????,??"); return properties; } SourceFunction sourceFunction = MySQLSource.bu
??????flink cdc ????mysql binlog?????? streaming????????????????????reload????????????????????
-- -- ??: "user-zh" <1