FlinkCDC讀取MySQL並寫入Kafka案例(com.alibaba.ververica)

場景應用：將MySQL的變化數據轉為實時流輸出到Kafka中。 注意版本問題，版本不同可能會出現異常，以下版本測試沒問題： flink1.12.7 flink-connector-mysq ...

FlinkCDC讀取MySQL並寫入Kafka案例(com.ververica)

該方法使用的是com.ververica版本的flink-connector-mysql-cdc，另一個版本測試也沒問題了，見https://www.cnblogs.com/30go/p/157733 ...

FlinkCDC在生產環境測試時一直報錯沒有MySQL的RELOAD權限

之前測試環境用root沒這個問題。換到生產環境指定的某個mysql賬號出現權限不足： 需要修改：這類權限的授權不是針對某個數據庫的，因此須使用on *.*來進行： 會遇到一系列權限 ...