Flink SQL/Table API 消費Kafka的json格式數據存到MySQL--存入MySQL經過繼承RichSinkFunction來實現

[另外一篇經過JDBCAppendTableSink方式實現存入MySQL：http://www.javashuo.com/article/p-vjjblxbp-gu.html ]java 完整代碼 附有Kafka生產json格式數據的代碼mysql package cn.flink; import org.apache.flink.api.common.typeinfo.Types; impo

>>阅读原文<<