《從0到1學習Flink》—— 如何自定義 Data Sink ?

前言 前篇文章 《從0到1學習Flink》—— Data Sink 介紹 介紹了 Flink Data Sink,也介紹了 Flink 自帶的 Sink,那麼如何自定義本身的 Sink 呢?這篇文章將寫一個 demo 教你們將從 Kafka Source 的數據 Sink 到 MySQL 中去。java 準備工做 咱們先來看下 Flink 從 Kafka topic 中獲取數據的 demo,首先你
相關文章
相關標籤/搜索