最近需要將用戶的mysql數據實時導入到hana中。

方案一為：mysql-cdc---->debezium-source-connector---->kafka----->debezium-sink-connector---->hana

方案一執行過程中，由于mysql的表中有字段類型為：datatime, 默認值為CURRENT_TIMESTAMP。經過測試驗證，該時間字段只要加上默認值，debezium-sink-connector就報錯：Invalid Java object for schema type INT64: class java.util.Long for field "null"。基本斷定這是kafka-connector的bug，于是尋找其他方案，由于flink-connector使用的人較多，社區較活躍，嘗試將kafka-connector換成：flink-connector，就是下面的方案二。

方案二為：mysql-cdc---->debezium-source-connector---->kafka----->flink-connector---->hana

經過驗證，方案二執行過程中沒有再出現方案一中的報錯問題。

總結

以上是生活随笔為你收集整理的dbz用connector入hana报错Invalid Java object for schema type INT64: class java.util.Long for field “null“的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。