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