Flink SQL/Table API 消費Kafka數據並存入MySQL(經過JDBCAppendTableSink方式來實現存入到MySQL)

[另外一篇Flink經過繼承RichSinkFunction來實現數據存入MySQL:https://blog.csdn.net/qq_39799876/article/details/91437749 ]java 這種方式實現存到MySQL,須要注意一些問題。 另外,須要添加 flink-jdbc 這個依賴。mysql import org.apache.flink.api.common.fun
相關文章
相關標籤/搜索